You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@servicemix.apache.org by gn...@apache.org on 2006/03/01 00:08:18 UTC
svn commit: r381813 -
/incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/components/util/TransformComponentSupport.java
Author: gnodet
Date: Tue Feb 28 15:08:16 2006
New Revision: 381813
URL: http://svn.apache.org/viewcvs?rev=381813&view=rev
Log:
Handle exchanges with an ERROR status, use send() instead of sendSync() to send the output message
Modified:
incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/components/util/TransformComponentSupport.java
Modified: incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/components/util/TransformComponentSupport.java
URL: http://svn.apache.org/viewcvs/incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/components/util/TransformComponentSupport.java?rev=381813&r1=381812&r2=381813&view=diff
==============================================================================
--- incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/components/util/TransformComponentSupport.java (original)
+++ incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/components/util/TransformComponentSupport.java Tue Feb 28 15:08:16 2006
@@ -37,6 +37,10 @@
// Skip done exchanges
if (exchange.getStatus() == ExchangeStatus.DONE) {
return;
+ // Handle error exchanges
+ } else if (exchange.getStatus() == ExchangeStatus.ERROR) {
+ done(exchange);
+ return;
}
NormalizedMessage in = getInMessage(exchange);
@@ -49,7 +53,7 @@
else {
InOnly outExchange = getExchangeFactory().createInOnlyExchange();
outExchange.setInMessage(out);
- getDeliveryChannel().sendSync(outExchange);
+ getDeliveryChannel().send(outExchange);
exchange.setStatus(ExchangeStatus.DONE);
}
} else {