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 2007/08/09 14:30:31 UTC
svn commit: r564186 -
/incubator/servicemix/branches/servicemix-3.1/core/servicemix-core/src/main/java/org/apache/servicemix/components/util/TransformComponentSupport.java
Author: gnodet
Date: Thu Aug 9 05:30:30 2007
New Revision: 564186
URL: http://svn.apache.org/viewvc?view=rev&rev=564186
Log:
SM-1026: CorrelationId and senderEndpoint properties are not setted on the lightweigth components using the TransformComponentSupport
Modified:
incubator/servicemix/branches/servicemix-3.1/core/servicemix-core/src/main/java/org/apache/servicemix/components/util/TransformComponentSupport.java
Modified: incubator/servicemix/branches/servicemix-3.1/core/servicemix-core/src/main/java/org/apache/servicemix/components/util/TransformComponentSupport.java
URL: http://svn.apache.org/viewvc/incubator/servicemix/branches/servicemix-3.1/core/servicemix-core/src/main/java/org/apache/servicemix/components/util/TransformComponentSupport.java?view=diff&rev=564186&r1=564185&r2=564186
==============================================================================
--- incubator/servicemix/branches/servicemix-3.1/core/servicemix-core/src/main/java/org/apache/servicemix/components/util/TransformComponentSupport.java (original)
+++ incubator/servicemix/branches/servicemix-3.1/core/servicemix-core/src/main/java/org/apache/servicemix/components/util/TransformComponentSupport.java Thu Aug 9 05:30:30 2007
@@ -59,6 +59,11 @@
out = exchange.createMessage();
} else {
outExchange = getExchangeFactory().createInOnlyExchange();
+ outExchange.setProperty(JbiConstants.SENDER_ENDPOINT, getService() + ":" + getEndpoint());
+ String processCorrelationId = (String)exchange.getProperty(JbiConstants.CORRELATION_ID);
+ if (processCorrelationId != null) {
+ outExchange.setProperty(JbiConstants.CORRELATION_ID, processCorrelationId);
+ }
out = outExchange.createMessage();
}
boolean txSync = exchange.isTransacted() && Boolean.TRUE.equals(exchange.getProperty(JbiConstants.SEND_SYNC));