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 <aldettin...@gmail.com>
Authored: Thu Dec 1 16:48:48 2016 +0100
Committer: Claus Ibsen <davscl...@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();
             }

Reply via email to