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));
    }
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
Dispatches messages to the job manager .