This is an automated email from the ASF dual-hosted git repository. apupier pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git
commit 9d8866747c352eba0fccc6f828821154310ee218 Author: smjain <[email protected]> AuthorDate: Thu Sep 24 11:45:05 2026 +0530 CAMEL-24941: camel-core - Assert that the producer threads of the new test completed Co-Authored-By: Claude Opus 5.5 <[email protected]> --- .../processor/aggregator/AggregateClosedCorrelationKeyRaceTest.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/core/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateClosedCorrelationKeyRaceTest.java b/core/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateClosedCorrelationKeyRaceTest.java index 35b28f65fb59..61e344a1efbb 100644 --- a/core/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateClosedCorrelationKeyRaceTest.java +++ b/core/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateClosedCorrelationKeyRaceTest.java @@ -39,6 +39,7 @@ import org.junit.jupiter.api.AfterEach; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; +import static org.junit.jupiter.api.Assertions.assertFalse; import static org.junit.jupiter.api.Assertions.assertTrue; import static org.junit.jupiter.api.Assertions.fail; @@ -100,6 +101,8 @@ class AggregateClosedCorrelationKeyRaceTest extends ContextTestSupport { releaseAggregate.countDown(); producerB.join(10000); producerC.join(10000); + assertFalse(producerB.isAlive(), "producer-B did not complete within 10 s"); + assertFalse(producerC.isAlive(), "producer-C did not complete within 10 s"); assertTrue(c.getException() instanceof ClosedCorrelationKeyException, "Expected ClosedCorrelationKeyException but was: " + c.getException()); @@ -150,6 +153,7 @@ class AggregateClosedCorrelationKeyRaceTest extends ContextTestSupport { // C fails to remove the group it read (optimistic locking) and is retried releaseAggregate.countDown(); producerC.join(10000); + assertFalse(producerC.isAlive(), "producer-C did not complete within 10 s"); assertTrue(c.getException() instanceof ClosedCorrelationKeyException, "Expected ClosedCorrelationKeyException but was: " + c.getException());
