From c8ab4d2bd2309978911fd73e660866ea70d370a8 Mon Sep 17 00:00:00 2001
From: joseph <joseph@depop.com>
Date: Mon, 10 Dec 2018 16:38:57 +0000
Subject: [PATCH 1/2] DD-9086 Add PREFETCH_COUNT setting for the kombu consumer

---
 event_consumer/conf/defaults.py | 3 +++
 event_consumer/handlers.py      | 2 ++
 2 files changed, 5 insertions(+)

diff --git a/event_consumer/conf/defaults.py b/event_consumer/conf/defaults.py
index df82fe2..7b5f31a 100644
--- a/event_consumer/conf/defaults.py
+++ b/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
diff --git a/event_consumer/handlers.py b/event_consumer/handlers.py
index dc02dcc..5a2ca0e 100644
--- a/event_consumer/handlers.py
+++ b/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("

From 9eb3c2e869c3bfbe3095d53881723f39e71ea52b Mon Sep 17 00:00:00 2001
From: joseph <joseph@depop.com>
Date: Mon, 10 Dec 2018 17:43:26 +0000
Subject: [PATCH 2/2] DD-9086 Bump version to 1.1.1

---
 event_consumer/__about__.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/event_consumer/__about__.py b/event_consumer/__about__.py
index 7aba741..737bb0c 100644
--- a/event_consumer/__about__.py
+++ b/event_consumer/__about__.py
@@ -1,4 +1,4 @@
-__version__ = '1.1.0'
+__version__ = '1.1.1'
 
 
 if __name__ == '__main__':