diff --git a/application/src/test/java/org/thingsboard/server/service/queue/ruleengine/TbRuleEngineQueueConsumerManagerTest.java b/application/src/test/java/org/thingsboard/server/service/queue/ruleengine/TbRuleEngineQueueConsumerManagerTest.java
index 20b765da6d..38582d0fce 100644
--- a/application/src/test/java/org/thingsboard/server/service/queue/ruleengine/TbRuleEngineQueueConsumerManagerTest.java
+++ b/application/src/test/java/org/thingsboard/server/service/queue/ruleengine/TbRuleEngineQueueConsumerManagerTest.java
@@ -184,7 +184,7 @@ public class TbRuleEngineQueueConsumerManagerTest {
         ruleEngineConsumerContext.stop();
 
         if (generateQueueMsgs) {
-            await().atMost(2, TimeUnit.SECONDS)
+            await().atMost(10, TimeUnit.SECONDS)
                     .untilAsserted(() -> {
                         log.debug("totalConsumedMsgs = {}, totalProcessedMsgs = {}", totalConsumedMsgs.get(), totalProcessedMsgs.get());
                         assertThat(totalProcessedMsgs.get()).isEqualTo(totalConsumedMsgs.get());