Fixed QueueLoadBalancer issue when callback is not executed when processor is not found.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/58e7aecf Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/58e7aecf Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/58e7aecf Branch: refs/heads/camel-2.12.x Commit: 58e7aecf6093efa50cb4b9411590164612b7f9de Parents: aca2e9e Author: nkukhar <[email protected]> Authored: Sun Jul 20 00:56:09 2014 -0700 Committer: Claus Ibsen <[email protected]> Committed: Sun Jul 20 10:07:59 2014 +0200 ---------------------------------------------------------------------- .../apache/camel/processor/loadbalancer/QueueLoadBalancer.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/58e7aecf/camel-core/src/main/java/org/apache/camel/processor/loadbalancer/QueueLoadBalancer.java ---------------------------------------------------------------------- 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 e86b751..778c57d 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 abstract class QueueLoadBalancer extends LoadBalancerSupport { 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;
