This is an automated email from the ASF dual-hosted git repository. orpiske pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git
commit 746f82eabe1bde2c1aad49b682c0baeb402585ee Author: Otavio Rodolfo Piske <[email protected]> AuthorDate: Fri Jul 14 09:05:30 2023 +0200 (chores) camel-core: PooledExchangeTest test fixes and cleanups - use Awaitility for wait for assertions --- .../src/test/java/org/apache/camel/processor/PooledExchangeTest.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/core/camel-core/src/test/java/org/apache/camel/processor/PooledExchangeTest.java b/core/camel-core/src/test/java/org/apache/camel/processor/PooledExchangeTest.java index 8ab45bbbdd7..bcf4a1a06cd 100644 --- a/core/camel-core/src/test/java/org/apache/camel/processor/PooledExchangeTest.java +++ b/core/camel-core/src/test/java/org/apache/camel/processor/PooledExchangeTest.java @@ -16,6 +16,7 @@ */ package org.apache.camel.processor; +import java.time.Duration; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicReference; @@ -30,6 +31,7 @@ import org.apache.camel.component.mock.MockEndpoint; import org.apache.camel.impl.engine.PooledExchangeFactory; import org.apache.camel.impl.engine.PooledProcessorExchangeFactory; import org.apache.camel.spi.PooledObjectFactory; +import org.awaitility.Awaitility; import org.junit.jupiter.api.Test; import static org.junit.jupiter.api.Assertions.assertEquals; @@ -72,7 +74,8 @@ class PooledExchangeTest extends ContextTestSupport { = context.getCamelContextExtension().getExchangeFactoryManager().getStatistics(); assertEquals(1, stat.getCreatedCounter()); assertEquals(2, stat.getAcquiredCounter()); - assertEquals(3, stat.getReleasedCounter()); + + Awaitility.await().atMost(Duration.ofSeconds(1)).untilAsserted(() -> assertEquals(3, stat.getReleasedCounter())); assertEquals(0, stat.getDiscardedCounter()); }
