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 4cde7ce99276bb9b906adff6e0d0327fe826dc47 Author: smjain <[email protected]> AuthorDate: Thu Sep 24 07:17:14 2026 +0530 CAMEL-24941: camel-core - Make the new test class package-private Co-Authored-By: Claude Opus 5.5 <[email protected]> --- .../processor/aggregator/AggregateClosedCorrelationKeyRaceTest.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) 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 61db6a5e0fad..35b28f65fb59 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 @@ -46,7 +46,7 @@ import static org.junit.jupiter.api.Assertions.fail; * An exchange that passed the closed correlation key check before the group of its key was completed (and the key * closed) must not start a new group for the closed key. */ -public class AggregateClosedCorrelationKeyRaceTest extends ContextTestSupport { +class AggregateClosedCorrelationKeyRaceTest extends ContextTestSupport { private final CountDownLatch inAggregate = new CountDownLatch(1); private final CountDownLatch releaseAggregate = new CountDownLatch(1); @@ -74,7 +74,7 @@ public class AggregateClosedCorrelationKeyRaceTest extends ContextTestSupport { } @Test - public void testExchangeWaitingForLockWhileKeyIsClosed() throws Exception { + void testExchangeWaitingForLockWhileKeyIsClosed() throws Exception { MockEndpoint mock = getMockEndpoint("mock:result"); mock.expectedBodiesReceived("A+B"); @@ -111,7 +111,7 @@ public class AggregateClosedCorrelationKeyRaceTest extends ContextTestSupport { } @Test - public void testOptimisticLockingRetryAfterKeyIsClosed() throws Exception { + void testOptimisticLockingRetryAfterKeyIsClosed() throws Exception { MockEndpoint mock = getMockEndpoint("mock:result"); mock.expectedBodiesReceived("A+B");
