wallabag/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
{
    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 15:36:57 +00:00			`<?php`

Enable Redis async import - using javibravo/simpleue - internal config value are now `import_with_redis` & `import_with_rabbit` which are more clear - if both option are enable rabbit will be choosen - services imports related to async are now splitted into 2 files: `redis.yml` & `rabbit.yml` - 2016-09-09 19:02:03 +00:00			`namespace Wallabag\ImportBundle\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 15:36:57 +00:00
			`use OldSound\RabbitMqBundle\RabbitMq\ConsumerInterface;`
			`use PhpAmqpLib\Message\AMQPMessage;`

AMPQ -> AMQP 2016-09-14 08:17:22 +00: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 15:36:57 +00: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 18:23:17 +00: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 15:36:57 +00:00			`}`
			`}`