src/Handler/SyncConsumerHandler.php
public function handle(Message $message)
    {
        $returnValue = $this->consumer->consume($message->getBody(), $message->getHeaders());
        $this->handleSyncMessage($message, $returnValue);

        return self::CONTINUE_CONSUMING;
    }
public function handle(Message $message)
    {
        $returnValue = $this->consumer->consume($message->getBody(), $message->getHeaders());
        $this->handleSyncMessage($message, $returnValue);

        return self::CONTINUE_CONSUMING;
    }
Handle a message.

@param Message $message

@return bool

@throws AssertionFailedException
@throws ConsumerException
@throws \InvalidArgumentException