protected function _actionProcess(AnCommandContext $context)
    {
        // run this no more than 1 minute
        //set_time_limit(60);

        $query = $this->getService('repos:notifications.notification')
                      ->getQuery(true)
                      ->status(ComNotificationsDomainEntityNotification::STATUS_NOT_SENT);

        if ($this->id) {
            $ids = (array) AnConfig::unbox($this->id);
            $query->id($ids);
        }

        $notifications = $query->fetchSet();

        $this->sendNotifications($notifications);
    }
protected function _actionProcess(AnCommandContext $context)
    {
        // run this no more than 1 minute
        //set_time_limit(60);

        $query = $this->getService('repos:notifications.notification')
                      ->getQuery(true)
                      ->status(ComNotificationsDomainEntityNotification::STATUS_NOT_SENT);

        if ($this->id) {
            $ids = (array) AnConfig::unbox($this->id);
            $query->id($ids);
        }

        $notifications = $query->fetchSet();

        $this->sendNotifications($notifications);
    }
protected function _actionProcess ( AnCommandContext $ context ) { // run this no more than 1 minute //set_time_limit(60); $ query = $ this -> getService ( 'repos:notifications.notification' ) -> getQuery ( true ) -> status ( ComNotificationsDomainEntityNotification :: STATUS_NOT_SENT ) ; if ( $ this -> id ) { $ ids = ( array ) AnConfig :: unbox ( $ this -> id ) ; $ query -> id ( $ ids ) ; } $ notifications = $ query -> fetchSet ( ) ; $ this -> sendNotifications ( $ notifications ) ; }
Process an array of notifications.

@param AnCommandContext $context
Process an array of notifications .