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 c0291dc08f03f2c9a4f53b6d1b502a4d8b5cca5b Author: smjain <[email protected]> AuthorDate: Thu Sep 24 07:38:45 2026 +0530 CAMEL-24953: camel-core - Make the new test class package-private Co-Authored-By: Claude Opus 5.5 <[email protected]> --- .../camel/processor/IdempotentConsumerFailedDuplicateTest.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/core/camel-core/src/test/java/org/apache/camel/processor/IdempotentConsumerFailedDuplicateTest.java b/core/camel-core/src/test/java/org/apache/camel/processor/IdempotentConsumerFailedDuplicateTest.java index f1c71b295903..1fa0885aedc4 100644 --- a/core/camel-core/src/test/java/org/apache/camel/processor/IdempotentConsumerFailedDuplicateTest.java +++ b/core/camel-core/src/test/java/org/apache/camel/processor/IdempotentConsumerFailedDuplicateTest.java @@ -37,7 +37,7 @@ import static org.junit.jupiter.api.Assertions.assertTrue; * With skipDuplicate=false a duplicate is routed on. If the duplicate fails, it must not remove the key that the * original exchange added. */ -public class IdempotentConsumerFailedDuplicateTest extends ContextTestSupport { +class IdempotentConsumerFailedDuplicateTest extends ContextTestSupport { private final IdempotentRepository repo = MemoryIdempotentRepository.memoryIdempotentRepository(200); private final CountDownLatch firstInProgress = new CountDownLatch(1); @@ -49,25 +49,25 @@ public class IdempotentConsumerFailedDuplicateTest extends ContextTestSupport { } @Test - public void testFailedDuplicateDoesNotRemoveKey() throws Exception { + void testFailedDuplicateDoesNotRemoveKey() throws Exception { addRoute(true, false); assertFailedDuplicateDoesNotRemoveKey(); } @Test - public void testFailedDuplicateDoesNotRemoveKeyCompletionEager() throws Exception { + void testFailedDuplicateDoesNotRemoveKeyCompletionEager() throws Exception { addRoute(true, true); assertFailedDuplicateDoesNotRemoveKey(); } @Test - public void testFailedDuplicateDoesNotRemoveKeyNonEager() throws Exception { + void testFailedDuplicateDoesNotRemoveKeyNonEager() throws Exception { addRoute(false, false); assertFailedDuplicateDoesNotRemoveKey(); } @Test - public void testFailedDuplicateDoesNotRemoveKeyOfInflightExchange() throws Exception { + void testFailedDuplicateDoesNotRemoveKeyOfInflightExchange() throws Exception { addRoute(true, false); MockEndpoint newMessages = getMockEndpoint("mock:new");
