Adapter/Bernard/ProducerAdapter.php
public function produce(Message $message)
    {
        $producerMessage = new PlainMessage('ConsumeJob', [
            'type' => $message->getType(),
            'ticket' => $message->getTicket()
        ]);

        $this->logger->debug('Publish message to bernard queue backend', ['message' => $message]);

        $this->producer->produce($producerMessage, $this->registry->get($message->getType())->getQueue());
    }
public function produce(Message $message)
    {
        $producerMessage = new PlainMessage('ConsumeJob', [
            'type' => $message->getType(),
            'ticket' => $message->getTicket()
        ]);

        $this->logger->debug('Publish message to bernard queue backend', ['message' => $message]);

        $this->producer->produce($producerMessage, $this->registry->get($message->getType())->getQueue());
    }
{@inheritdoc}