servicemix-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gno...@apache.org
Subject svn commit: r564186 - /incubator/servicemix/branches/servicemix-3.1/core/servicemix-core/src/main/java/org/apache/servicemix/components/util/TransformComponentSupport.java
Date Thu, 09 Aug 2007 12:30:31 GMT
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));



Mime
View raw message