Merge pull request #2 from ingresse/feature/exchange-subscribe

Adding method to subscribe to a exchange

Author: Corcioli

message_queue/adapters/amqp_adapter.py

@@ -171,3 +171,26 @@ def _consume_acknowledge(self, channel, tag, acknowledge=True):
 
         channel.basic_ack(delivery_tag=tag)
 
+    def subscribe(self, exchange, queue, exchange_type="fanout", **kwargs):
+        """Subscribes to a exchange.
+
+        :param function worker: Method that consume the message
+        :param string exchange: Exchange name
+        :param string exchange: Queue name
+        :param string exchange_type: Exchange type
+
+        """
+        self.queue = queue
+        self.channel.exchange_declare(
+            exchange=exchange, exchange_type=exchange_type)
+
+        self.channel.queue_declare(
+            queue=self.queue,
+            passive=kwargs.get('passive', False),
+            durable=kwargs.get('durable', True),
+            exclusive=kwargs.get('exclusive', False),
+            auto_delete=kwargs.get('auto_delete', False),
+            arguments=kwargs.get('arguments', None)
+        )
+
+        self.channel.queue_bind(exchange=exchange, queue=self.queue)