You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ni...@apache.org on 2008/11/07 06:36:07 UTC
svn commit: r712064 -
/activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/HandleFaultProcessor.java
Author: ningjiang
Date: Thu Nov 6 21:36:07 2008
New Revision: 712064
URL: http://svn.apache.org/viewvc?rev=712064&view=rev
Log:
CAMEL-1058 fixed the HandleFaultProcessor's bug
Modified:
activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/HandleFaultProcessor.java
Modified: activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/HandleFaultProcessor.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/HandleFaultProcessor.java?rev=712064&r1=712063&r2=712064&view=diff
==============================================================================
--- activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/HandleFaultProcessor.java (original)
+++ activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/HandleFaultProcessor.java Thu Nov 6 21:36:07 2008
@@ -46,7 +46,7 @@
return ((AsyncProcessor)processor).process(exchange, new AsyncCallback() {
public void done(boolean doneSynchronously) {
- callback.done(doneSynchronously);
+ // Take the fault message out before we keep on going
Message faultMessage = exchange.getFault(false);
if (faultMessage != null) {
final Object faultBody = faultMessage.getBody();
@@ -59,7 +59,8 @@
+ faultBody.getClass().getName() + ":\n" + faultBody));
}
}
- }
+ }
+ callback.done(doneSynchronously);
}
});
}