From 03a6b58269a0c8bda740ad7af1f32079cbcc3bc6 Mon Sep 17 00:00:00 2001 From: nkukhar Date: Sun, 20 Jul 2014 00:56:09 -0700 Subject: [PATCH] Fixed QueueLoadBalancer issue when callback is not executed when processor is not found. --- .../apache/camel/processor/loadbalancer/QueueLoadBalancer.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/camel-core/src/main/java/org/apache/camel/processor/loadbalancer/QueueLoadBalancer.java b/camel-core/src/main/java/org/apache/camel/processor/loadbalancer/QueueLoadBalancer.java index e86b751f36eaa..778c57dee9d86 100644 --- a/camel-core/src/main/java/org/apache/camel/processor/loadbalancer/QueueLoadBalancer.java +++ b/camel-core/src/main/java/org/apache/camel/processor/loadbalancer/QueueLoadBalancer.java @@ -36,7 +36,8 @@ public boolean process(final Exchange exchange, final AsyncCallback callback) { if (!list.isEmpty()) { Processor processor = chooseProcessor(list, exchange); if (processor == null) { - throw new IllegalStateException("No processors could be chosen to process " + exchange); + Exception e = new IllegalStateException("No processors could be chosen to process " + exchange); + exchange.setException(e); } else { if (processor instanceof AsyncProcessor) { AsyncProcessor async = (AsyncProcessor) processor;