Merge pull request #14 from depop/DD-9086-add-consumer-prefetch-count

DD-9086 Add PREFETCH_COUNT setting for the kombu consumer

event_consumer/__about__.py

@@ -1,4 +1,4 @@
-__version__ = '1.1.0'
+__version__ = '1.1.1'
 
 
 if __name__ == '__main__':

event_consumer/conf/defaults.py

@@ -28,6 +28,9 @@
 
 RETRY_HEADER = 'x-retry-count'
 
+# Set the consumer prefetch limit
+PREFETCH_COUNT = 1
+
 # to set TTL for archived message (milliseconds)
 ARCHIVE_EXPIRY = int(timedelta(days=24).total_seconds() * 1000)  # type: int
 # max size of archive queue before dropping messages

event_consumer/handlers.py

@@ -300,6 +300,8 @@ def __init__(self,
             accept=settings.ACCEPT,
         )
 
+        self.consumer.qos(prefetch_count=settings.PREFETCH_COUNT)
+
     def __repr__(self):
         return (
             "AMQPRetryHandler("