camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject [1/2] git commit: Fixed QueueLoadBalancer issue when callback is not executed when processor is not found.
Date Sun, 20 Jul 2014 08:08:07 GMT
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 <kukhar.n@gmail.com>
Authored: Sun Jul 20 00:56:09 2014 -0700
Committer: Claus Ibsen <davsclaus@apache.org>
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;


Mime
View raw message