Added prefetch count

ingresse · Aug 10, 2018 · 6ab33f4 · 6ab33f4
1 parent 8674039
commit 6ab33f4
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/message_queue/__init__.py b/message_queue/__init__.py
@@ -1,4 +1,4 @@
-__version__ = '0.2.2'
+__version__ = '0.2.3'
 
 from message_queue.logger import *
 

diff --git a/message_queue/adapters/amqp_adapter.py b/message_queue/adapters/amqp_adapter.py
@@ -212,4 +212,5 @@ def subscribe(self, exchange, queue, exchange_type="fanout", **kwargs):
             arguments=kwargs.get('arguments', None)
         )
 
+        self.channel.basic_qos(prefetch_count=kwargs.get('prefetch_count', 1))
         self.channel.queue_bind(exchange=exchange, queue=self.queue)