Repository: camel Updated Branches: refs/heads/camel-2.12.x aca2e9ee1 -> 58e7aecf6 refs/heads/camel-2.13.x 1ccc2c982 -> 821d568ab
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/821d568a Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/821d568a Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/821d568a Branch: refs/heads/camel-2.13.x Commit: 821d568ab63aa70a64498964a5ca9d884a3549d9 Parents: 1ccc2c9 Author: nkukhar <[email protected]> Authored: Sun Jul 20 00:56:09 2014 -0700 Committer: Claus Ibsen <[email protected]> Committed: Sun Jul 20 10:07:50 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/821d568a/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;
