add rabbitmq to nab3a bundle.

Author: bangpound

RabbitMq/EnqueueTweetPlugin.php

@@ -0,0 +1,45 @@
+<?php
+
+namespace RShief\Nab3aBundle\RabbitMq;
+
+use RShief\Nab3aBundle\Evenement\PluginInterface;
+use Evenement\EventEmitterInterface;
+use OldSound\RabbitMqBundle\RabbitMq\ProducerInterface;
+
+class EnqueueTweetPlugin implements PluginInterface
+{
+    /**
+     * @var ProducerInterface
+     */
+    private $producer;
+    /**
+     * @var string
+     */
+    private $routingKey;
+    /**
+     * @var array
+     */
+    private $additionalProperties;
+
+    public function __construct(ProducerInterface $producer, $routingKey = '', $additionalProperties = array())
+    {
+        $this->producer = $producer;
+        $this->routingKey = $routingKey;
+        $this->additionalProperties = $additionalProperties;
+    }
+
+    public function attachEvents(EventEmitterInterface $emitter)
+    {
+        $emitter->on('tweet', function ($data) {
+            $data = json_encode($data);
+            $this->producer->publish($data, $this->routingKey, $this->additionalProperties);
+        });
+    }
+
+    /**
+     * @param $data
+     */
+    private function enqueue($data)
+    {
+    }
+}

Resources/config/rabbitmq.yml

@@ -0,0 +1,10 @@
+services:
+    nab3a.twitter.message_emitter.plugin.rabbitmq:
+        class: RShief\Nab3aBundle\RabbitMq\EnqueueTweetPlugin
+        arguments:
+            - '@old_sound_rabbit_mq.twitter_producer'
+            - 'twitter'
+            - { content_type: 'application/json' }
+        public: false
+        tags:
+            - { name: evenement.plugin, id: nab3a.twitter.message_emitter }

Resources/config/services.yml

@@ -4,6 +4,7 @@ imports:
   - { resource: console.yml }
   - { resource: stream.yml }
   - { resource: event_loop.yml }
+  - { resource: rabbitmq.yml }
 
 services:
   nab3a.standalone.parameters: