WorkflowBundle/Services/TaskLoggerService.php

<?php

namespace WorkflowBundle\Services;

use OldSound\RabbitMqBundle\RabbitMq\ConsumerInterface;
use PhpAmqpLib\Message\AMQPMessage;

class TaskLoggerService implements ConsumerInterface
{

    /**
     * @param AMQPMessage $msg
     */
    public function execute(AMQPMessage $msg)
    {
        //$msg will be an instance of `PhpAmqpLib\Message\AMQPMessage` with the $msg->body being the data sent over RabbitMQ.

        $data = $msg->body;
        
        return true;
    }

}