pulse_actions/worker.py | 1 +
 1 file changed, 1 insertion(+)

diff --git a/pulse_actions/worker.py b/pulse_actions/worker.py
index 2d34d17..37517bd 100644
--- a/pulse_actions/worker.py
+++ b/pulse_actions/worker.py
@@ -395,16 +395,17 @@ def run_listener(config_file):
         sys.exit(1)

     consumer = create_consumer(
         user=os.environ['PULSE_USER'],
         password=os.environ['PULSE_PW'],
         config_file_path=config_file,
         process_message=message_handler,
     )
+    consumer.qos(prefetch_size=0, prefetch_count=1, apply_global=False)

     while True:
         try:
             consumer.listen()
         except KeyboardInterrupt:
             sys.exit(1)
         except:
             traceback.print_exc()