public function executeQueue(Queue $queue, $max, $timeout = 30)
    {
        foreach($this->receiveQueueMessages($queue, $max, $timeout) as $message) {
            try {
                $message->execute();
                $this->deleteMessage($message);
            } catch(\Exception $e) {
                $this->log($message, $e);
            }
        }
    }
public function executeQueue(Queue $queue, $max, $timeout = 30)
    {
        foreach($this->receiveQueueMessages($queue, $max, $timeout) as $message) {
            try {
                $message->execute();
                $this->deleteMessage($message);
            } catch(\Exception $e) {
                $this->log($message, $e);
            }
        }
    }
public function executeQueue ( Queue $ queue , $ max , $ timeout = 30 ) { foreach ( $ this -> receiveQueueMessages ( $ queue , $ max , $ timeout ) as $ message ) { try { $ message -> execute ( ) ; $ this -> deleteMessage ( $ message ) ; } catch ( \ Exception $ e ) { $ this -> log ( $ message , $ e ) ; } } }
Execute messages in queue

@param Queue $queue
@param int $max
@param int $timeout
Execute messages in queue