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 116bdd8fc7c13f9b4ba55d93643f40372af28818 Author: smjain <[email protected]> AuthorDate: Wed Sep 23 18:48:24 2026 +0530 CAMEL-24923: camel-core - Signal completion like the other exits of QueueLoadBalancer.process Use callback.done(false) / return false when choosing the processor fails, as the other exits of the method do. Co-Authored-By: Claude Opus 5.5 <[email protected]> --- .../org/apache/camel/processor/loadbalancer/QueueLoadBalancer.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/core/camel-core-processor/src/main/java/org/apache/camel/processor/loadbalancer/QueueLoadBalancer.java b/core/camel-core-processor/src/main/java/org/apache/camel/processor/loadbalancer/QueueLoadBalancer.java index 64d29bb702de..9b705d41d9d8 100644 --- a/core/camel-core-processor/src/main/java/org/apache/camel/processor/loadbalancer/QueueLoadBalancer.java +++ b/core/camel-core-processor/src/main/java/org/apache/camel/processor/loadbalancer/QueueLoadBalancer.java @@ -35,8 +35,8 @@ public abstract class QueueLoadBalancer extends LoadBalancerSupport { processor = chooseProcessor(list, exchange); } catch (Exception e) { exchange.setException(e); - callback.done(true); - return true; + callback.done(false); + return false; } if (processor == null) { Exception e = new IllegalStateException("No processors could be chosen to process " + exchange);
