Repository: camel Updated Branches: refs/heads/master 1f92fa424 -> cfaa6727b
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/03a6b582 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/03a6b582 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/03a6b582 Branch: refs/heads/master Commit: 03a6b58269a0c8bda740ad7af1f32079cbcc3bc6 Parents: fa7e773 Author: nkukhar <[email protected]> Authored: Sun Jul 20 00:56:09 2014 -0700 Committer: nkukhar <[email protected]> Committed: Sun Jul 20 00:56:09 2014 -0700 ---------------------------------------------------------------------- .../apache/camel/processor/loadbalancer/QueueLoadBalancer.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/03a6b582/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;
