src/Connector/RabbitConnector.php
protected function prepareMessage($queue, Job $job)
    {
        $this->queueDeclare($queue);

        return new AMQPMessage(json_encode($job->createPayload()), $job->getOptions());
    }
protected function prepareMessage($queue, Job $job)
    {
        $this->queueDeclare($queue);

        return new AMQPMessage(json_encode($job->createPayload()), $job->getOptions());
    }
protected function prepareMessage ( $ queue , Job $ job ) { $ this -> queueDeclare ( $ queue ) ; return new AMQPMessage ( json_encode ( $ job -> createPayload ( ) ) , $ job -> getOptions ( ) ) ; }
Prepares a message

@param string $queue
@param Job    $job

@return AMQPMessage

@codeCoverageIgnore
Prepares a message