[github/wallabag/wallabag.git] / src / Wallabag / ImportBundle / Consumer / AMQPEntryConsumer.php

<?php

namespace Wallabag\ImportBundle\Consumer;

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

class AMQPEntryConsumer extends AbstractConsumer implements ConsumerInterface
{
    /**
     * {@inheritdoc}
     */
    public function execute(AMQPMessage $msg)
    {
        return $this->handleMessage($msg->body);
    }
}
Commit	Line	Data
ef75e122 JB	1	<?php
ef75e122 JB	2
b3437d58	3	namespace Wallabag\ImportBundle\Consumer;
ef75e122	4
ef75e122 JB	5	use OldSound\RabbitMqBundle\RabbitMq\ConsumerInterface;
ef75e122 JB	6	use PhpAmqpLib\Message\AMQPMessage;
ef75e122	7
ac87e0db	8	class AMQPEntryConsumer extends AbstractConsumer implements ConsumerInterface
ef75e122	9	{
ef75e122 JB	10	/**
	11	* {@inheritdoc}
	12	*/
	13	public function execute(AMQPMessage $msg)
	14	{
7d862f83	15	return $this->handleMessage($msg->body);
ef75e122 JB	16	}
ef75e122 JB	17	}