From d4eaac7711f2e7d79606cf6322b51d4bb734c37b Mon Sep 17 00:00:00 2001 From: Andrii Shvaika Date: Mon, 6 Nov 2023 18:33:48 +0200 Subject: [PATCH] Fix queue test --- .../ruleengine/TbRuleEngineQueueConsumerManagerTest.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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 05eacc68e3..6acf71e2bb 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 @@ -458,7 +458,7 @@ public class TbRuleEngineQueueConsumerManagerTest { verify(consumer2, never()).unsubscribe(); int msgCount = totalConsumedMsgs.get(); - await().atLeast(4, TimeUnit.SECONDS) // based on topicDeletionDelayInSec + await().atLeast(2, TimeUnit.SECONDS) // based on topicDeletionDelayInSec(5) = 5 - ( 3 seconds the code may execute starting consumerManager.delete() call) .atMost(7, TimeUnit.SECONDS) .untilAsserted(() -> { partitions.stream() @@ -498,7 +498,7 @@ public class TbRuleEngineQueueConsumerManagerTest { verify(consumer, never()).unsubscribe(); int msgCount = totalConsumedMsgs.get(); - await().atLeast(4, TimeUnit.SECONDS) + await().atLeast(2, TimeUnit.SECONDS) // based on topicDeletionDelayInSec(5) = 5 - ( 3 seconds the code may execute starting consumerManager.delete() call) .atMost(7, TimeUnit.SECONDS) .untilAsserted(() -> { partitions.stream()