|
|
@ -184,7 +184,7 @@ public class TbRuleEngineQueueConsumerManagerTest { |
|
|
ruleEngineConsumerContext.stop(); |
|
|
ruleEngineConsumerContext.stop(); |
|
|
|
|
|
|
|
|
if (generateQueueMsgs) { |
|
|
if (generateQueueMsgs) { |
|
|
await().atMost(2, TimeUnit.SECONDS) |
|
|
await().atMost(10, TimeUnit.SECONDS) |
|
|
.untilAsserted(() -> { |
|
|
.untilAsserted(() -> { |
|
|
log.debug("totalConsumedMsgs = {}, totalProcessedMsgs = {}", totalConsumedMsgs.get(), totalProcessedMsgs.get()); |
|
|
log.debug("totalConsumedMsgs = {}, totalProcessedMsgs = {}", totalConsumedMsgs.get(), totalProcessedMsgs.get()); |
|
|
assertThat(totalProcessedMsgs.get()).isEqualTo(totalConsumedMsgs.get()); |
|
|
assertThat(totalProcessedMsgs.get()).isEqualTo(totalConsumedMsgs.get()); |
|
|
|