You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2016/12/01 20:03:11 UTC
[2/2] camel git commit: CAMEL-10272: Added a debug log covering for
instance a runtime exception thrown from a custom aggregation strategy
CAMEL-10272: Added a debug log covering for instance a runtime exception thrown from a custom aggregation strategy
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/62d19db0
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/62d19db0
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/62d19db0
Branch: refs/heads/master
Commit: 62d19db070a1b2c6a83f3ccd942b72f90c3cba37
Parents: 5fa4f3e
Author: aldettinger <al...@gmail.com>
Authored: Thu Dec 1 16:48:48 2016 +0100
Committer: Claus Ibsen <da...@apache.org>
Committed: Thu Dec 1 21:01:46 2016 +0100
----------------------------------------------------------------------
.../main/java/org/apache/camel/processor/MulticastProcessor.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/62d19db0/camel-core/src/main/java/org/apache/camel/processor/MulticastProcessor.java
----------------------------------------------------------------------
diff --git a/camel-core/src/main/java/org/apache/camel/processor/MulticastProcessor.java b/camel-core/src/main/java/org/apache/camel/processor/MulticastProcessor.java
index 5c5b361..e0cd13d 100644
--- a/camel-core/src/main/java/org/apache/camel/processor/MulticastProcessor.java
+++ b/camel-core/src/main/java/org/apache/camel/processor/MulticastProcessor.java
@@ -531,7 +531,9 @@ public class MulticastProcessor extends ServiceSupport implements AsyncProcessor
}
} catch (Throwable e) {
// wrap in exception to explain where it failed
- subExchange.setException(new CamelExchangeException("Parallel processing failed for number " + aggregated.get(), subExchange, e));
+ CamelExchangeException cex = new CamelExchangeException("Parallel processing failed for number " + aggregated.get(), subExchange, e);
+ subExchange.setException(cex);
+ LOG.debug(cex.getMessage(), cex);
} finally {
aggregated.incrementAndGet();
}