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__':
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("