wallabag/src/Consumer/AMQPEntryConsumer.php

<?php

namespace Wallabag\Consumer;

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

class AMQPEntryConsumer extends AbstractConsumer implements ConsumerInterface
{
    public function execute(AMQPMessage $msg)
    {
        return $this->handleMessage($msg->body);
    }
}
Send every imported item to the queue Instead of queing real Entry to process, we queue all the item to import from Pocket in a raw format. Then, the worker retrieve that information, find / create the entry and save it. 2016-09-03 17:36:57 +02:00			`<?php`

Remove the CoreBundle namespace 2024-02-19 01:30:12 +01:00			`namespace Wallabag\Consumer;`
Send every imported item to the queue Instead of queing real Entry to process, we queue all the item to import from Pocket in a raw format. Then, the worker retrieve that information, find / create the entry and save it. 2016-09-03 17:36:57 +02:00
			`use OldSound\RabbitMqBundle\RabbitMq\ConsumerInterface;`
			`use PhpAmqpLib\Message\AMQPMessage;`

AMPQ -> AMQP 2016-09-14 10:17:22 +02:00			`class AMQPEntryConsumer extends AbstractConsumer implements ConsumerInterface`
Send every imported item to the queue Instead of queing real Entry to process, we queue all the item to import from Pocket in a raw format. Then, the worker retrieve that information, find / create the entry and save it. 2016-09-03 17:36:57 +02:00			`{`
			`public function execute(AMQPMessage $msg)`
			`{`
Re-facto EntryConsumer Using an abstract method allow to share code but also can be used it we add a new broker in the future 2016-09-11 20:23:17 +02:00			`return $this->handleMessage($msg->body);`
Send every imported item to the queue Instead of queing real Entry to process, we queue all the item to import from Pocket in a raw format. Then, the worker retrieve that information, find / create the entry and save it. 2016-09-03 17:36:57 +02:00			`}`
			`}`