(camel) branch main updated: Reduce flakiness of RedeliveryErrorHandlerNonBlockedRedeliveryHeaderTest

[apupier]

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


The following commit(s) were added to refs/heads/main by this push:
     new a8ff50c9d8b6 Reduce flakiness of 
RedeliveryErrorHandlerNonBlockedRedeliveryHeaderTest
a8ff50c9d8b6 is described below

commit a8ff50c9d8b65fc3ac94c0a082cec53e19d1d279
Author: Aurélien Pupier <apup...@ibm.com>
AuthorDate: Fri Jul 24 17:09:50 2026 +0200

    Reduce flakiness of RedeliveryErrorHandlerNonBlockedRedeliveryHeaderTest
    
    after a first failure, the 2nd and 3rd run were always failing because
    the counter was not reset.
    
    also fixed the first mock endpoint, previously it was checking 2 times
    the same mock endpoint
    
    Signed-off-by: Aurélien Pupier <apup...@ibm.com>
---
 ...RedeliveryErrorHandlerNonBlockedRedeliveryHeaderTest.java | 12 +++++++++---
 1 file changed, 9 insertions(+), 3 deletions(-)

diff --git 
a/core/camel-core/src/test/java/org/apache/camel/processor/RedeliveryErrorHandlerNonBlockedRedeliveryHeaderTest.java
 
b/core/camel-core/src/test/java/org/apache/camel/processor/RedeliveryErrorHandlerNonBlockedRedeliveryHeaderTest.java
index 3491c24a7d2f..d551e974406f 100644
--- 
a/core/camel-core/src/test/java/org/apache/camel/processor/RedeliveryErrorHandlerNonBlockedRedeliveryHeaderTest.java
+++ 
b/core/camel-core/src/test/java/org/apache/camel/processor/RedeliveryErrorHandlerNonBlockedRedeliveryHeaderTest.java
@@ -23,6 +23,7 @@ import org.apache.camel.Exchange;
 import org.apache.camel.Processor;
 import org.apache.camel.builder.RouteBuilder;
 import org.apache.camel.component.mock.MockEndpoint;
+import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -31,12 +32,17 @@ public class 
RedeliveryErrorHandlerNonBlockedRedeliveryHeaderTest extends Contex
 
     private static final Logger LOG = 
LoggerFactory.getLogger(RedeliveryErrorHandlerNonBlockedRedeliveryHeaderTest.class);
 
-    private static final LongAdder attempt = new LongAdder();
+    private static LongAdder attempt;
+
+    @BeforeEach
+    void setup() {
+        attempt = new LongAdder();
+    }
 
     @Test
     public void testRedelivery() throws Exception {
-        MockEndpoint before = getMockEndpoint("mock:result");
-        before.expectedBodiesReceived("Hello World", "Hello Camel");
+        MockEndpoint before = getMockEndpoint("mock:before");
+        before.expectedBodiesReceived("World", "Camel");
 
         // we use NON blocked redelivery delay so the messages arrive which
         // completes first