]>
Commit | Line | Data |
---|---|---|
ef75e122 JB |
1 | <?php |
2 | ||
b3437d58 | 3 | namespace Wallabag\ImportBundle\Consumer; |
ef75e122 | 4 | |
ef75e122 JB |
5 | use OldSound\RabbitMqBundle\RabbitMq\ConsumerInterface; |
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 | } |
17 | } |