From 6d7cb95492c1a90fc55dab13a5f3d95a563bf690 Mon Sep 17 00:00:00 2001 From: ViacheslavKlimov Date: Fri, 20 Oct 2023 15:46:53 +0300 Subject: [PATCH] Bigger timeout in tests for msg processing --- .../queue/ruleengine/TbRuleEngineQueueConsumerManagerTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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());