public function executeCommand($queue, $messageCacheIdentifier)
    {
        if(!$this->messageCache->has($messageCacheIdentifier)) {
            throw new JobQueueException(sprintf('No message with identifier %s was found in the message cache.', $messageCacheIdentifier), 1517868903);
        }

        /** @var Message $message */
        $message = $this->messageCache->get($messageCacheIdentifier);
        $queue = $this->queueManager->getQueue($queue);
        $this->jobManager->executeJobForMessage($queue, $message);
    }
public function executeCommand($queue, $messageCacheIdentifier)
    {
        if(!$this->messageCache->has($messageCacheIdentifier)) {
            throw new JobQueueException(sprintf('No message with identifier %s was found in the message cache.', $messageCacheIdentifier), 1517868903);
        }

        /** @var Message $message */
        $message = $this->messageCache->get($messageCacheIdentifier);
        $queue = $this->queueManager->getQueue($queue);
        $this->jobManager->executeJobForMessage($queue, $message);
    }
public function executeCommand ( $ queue , $ messageCacheIdentifier ) { if ( ! $ this -> messageCache -> has ( $ messageCacheIdentifier ) ) { throw new JobQueueException ( sprintf ( 'No message with identifier %s was found in the message cache.' , $ messageCacheIdentifier ) , 1517868903 ) ; } /** @var Message $message */ $ message = $ this -> messageCache -> get ( $ messageCacheIdentifier ) ; $ queue = $ this -> queueManager -> getQueue ( $ queue ) ; $ this -> jobManager -> executeJobForMessage ( $ queue , $ message ) ; }
Execute one job

@param string $queue
@param string $messageCacheIdentifier An identifier to receive the message from the cache
@return void
@internal This command is mainly used by the JobManager and FakeQueue in order to execute commands in sub requests
@throws JobQueueException
Execute one job