src/Wallabag/ImportBundle/Redis/Producer.php

   1 <?php
   2
   3 namespace Wallabag\ImportBundle\Redis;
   4
   5 use OldSound\RabbitMqBundle\RabbitMq\ProducerInterface;
   6 use Simpleue\Queue\RedisQueue;
   7
   8 /**
   9  * This is a proxy class for "Simpleue\Queue\RedisQueue".
  10  * It allow us to use the same way to publish a message between RabbitMQ & Redis: publish().
  11  *
  12  * It implements the ProducerInterface of RabbitMQ (yes it's ugly) so we can have the same
  13  * kind of class which implements the same interface.
  14  * So we can inject either a RabbitMQ producer or a Redis producer with the same signature
  15  */
  16 class Producer implements ProducerInterface
  17 {
  18     private $queue;
  19
  20     public function __construct(RedisQueue $queue)
  21     {
  22         $this->queue = $queue;
  23     }
  24
  25     /**
  26      * Publish a message in the Redis queue.
  27      *
  28      * @param string $msgBody
  29      * @param string $routingKey           NOT USED
  30      * @param array  $additionalProperties NOT USED
  31      */
  32     public function publish($msgBody, $routingKey = '', $additionalProperties = [])
  33     {
  34         $this->queue->sendJob($msgBody);
  35     }
  36 }