Merge pull request #6 from ingresse/feature/exchange-prefetch-count

Prefetch Count
ingresse · Aug 10, 2018 · 2db918c · 2db918c
2 parents 8674039 + 69823b6
commit 2db918c
Showing 1 changed file with 1 addition and 0 deletions.
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)