src/Wallabag/ImportBundle/Consumer/AMQPEntryConsumer.php

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