svn commit: r564186 - /incubator/servicemix/branches/servicemix-3.1/core/servicemix-core/src/main/java/org/apache/servicemix/components/util/TransformComponentSupport.java

[gnodet]

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));