Adapter/Bernard/ProducerAdapter.php
public function consumeJob(PlainMessage $message){

        $ticket = $message->ticket;
        $type = $message->type;

        $this->logger->debug('Consume message from bernard backend', [
            'message' => $message
        ]);

        $this->manager->onMessage(new Message($type, $ticket));
    }
public function consumeJob(PlainMessage $message){

        $ticket = $message->ticket;
        $type = $message->type;

        $this->logger->debug('Consume message from bernard backend', [
            'message' => $message
        ]);

        $this->manager->onMessage(new Message($type, $ticket));
    }
Dispatches messages to the job manager.

This method is registered as the message handler for messages with name "ConsumeJob".

@param PlainMessage $message
@throws \Abc\Bundle\JobBundle\Job\Exception\TicketNotFoundException