(camel) branch main updated: Fixed

[davsclaus]

This is an automated email from the ASF dual-hosted git repository.

davsclaus 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 0c03b30d0f3c Fixed
0c03b30d0f3c is described below

commit 0c03b30d0f3c227d994a9402424b54512975d710
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Sat Jun 13 07:58:21 2026 +0200

    Fixed
---
 .../throttle/concurrent/ConcurrentRequestsThrottlerTest.java     | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

diff --git 
a/core/camel-core/src/test/java/org/apache/camel/processor/throttle/concurrent/ConcurrentRequestsThrottlerTest.java
 
b/core/camel-core/src/test/java/org/apache/camel/processor/throttle/concurrent/ConcurrentRequestsThrottlerTest.java
index 3a377e5d48ab..75a4822b947b 100644
--- 
a/core/camel-core/src/test/java/org/apache/camel/processor/throttle/concurrent/ConcurrentRequestsThrottlerTest.java
+++ 
b/core/camel-core/src/test/java/org/apache/camel/processor/throttle/concurrent/ConcurrentRequestsThrottlerTest.java
@@ -213,12 +213,17 @@ public class ConcurrentRequestsThrottlerTest extends 
ContextTestSupport {
                             assertTrue(s.tryAcquire(), 
"'direct:expressionConstant' too many requests");
                             
exchange.getExchangeExtension().addOnCompletion(new SynchronizationAdapter() {
                                 @Override
-                            
exchange.getExchangeExtension().addOnCompletion(new SynchronizationAdapter() {
+                                public void onComplete(Exchange ex) {
+                                    s.release();
+                                }
+
                                 @Override
-                                public void onDone(Exchange ex) {
+                                public void onFailure(Exchange ex) {
                                     s.release();
                                 }
                             });
+                        })
+                        .delay(100)
                         .to("log:result", "mock:result");
 
                 
from("direct:expressionHeader").throttle(header("throttleValue")).concurrentRequestsMode()