diff --git a/src/tests/integration/rmqapitests/consumer_tests.py b/src/tests/integration/rmqapitests/consumer_tests.py
index 4472849..0829901 100644
--- a/src/tests/integration/rmqapitests/consumer_tests.py
+++ b/src/tests/integration/rmqapitests/consumer_tests.py
@@ -69,7 +69,7 @@ def test_consume_n_messages(self):
             assert response["routed"] is True
 
         if not self.wait_for_message_consumption(
-            qname, 10, success_on_queue_delete=True
+            qname, count=10, timeout=120, success_on_queue_delete=True
         ):
             pytest.fail("Consumer is not able to consume the message.")