svn commit: r478818 - /incubator/servicemix/trunk/common/servicemix-components/src/main/java/org/apache/servicemix/components/drools/DroolsComponent.java

[gnodet]

Author: gnodet
Date: Fri Nov 24 01:46:45 2006
New Revision: 478818

URL: http://svn.apache.org/viewvc?view=rev&rev=478818
Log:
SM-751: Flow tracing with correlation id.
Patch provided by Gianfranco Boccalon

Modified:
    
incubator/servicemix/trunk/common/servicemix-components/src/main/java/org/apache/servicemix/components/drools/DroolsComponent.java

Modified: 
incubator/servicemix/trunk/common/servicemix-components/src/main/java/org/apache/servicemix/components/drools/DroolsComponent.java
URL: 
http://svn.apache.org/viewvc/incubator/servicemix/trunk/common/servicemix-components/src/main/java/org/apache/servicemix/components/drools/DroolsComponent.java?view=diff&rev=478818&r1=478817&r2=478818
==============================================================================
--- 
incubator/servicemix/trunk/common/servicemix-components/src/main/java/org/apache/servicemix/components/drools/DroolsComponent.java
 (original)
+++ 
incubator/servicemix/trunk/common/servicemix-components/src/main/java/org/apache/servicemix/components/drools/DroolsComponent.java
 Fri Nov 24 01:46:45 2006
@@ -30,6 +30,7 @@
 import javax.jbi.messaging.NormalizedMessage;
 import javax.xml.namespace.QName;
 
+import org.apache.servicemix.JbiConstants;
 import org.apache.servicemix.components.util.OutBinding;
 import org.drools.FactException;
 import org.drools.RuleBase;
@@ -80,6 +81,10 @@
         DeliveryChannel channel = getDeliveryChannel();
         MessageExchangeFactory factory = 
channel.createExchangeFactoryForService(name);
         InOnly outExchange = factory.createInOnlyExchange();
+        String processCorrelationId = 
(String)exchange.getProperty(JbiConstants.CORRELATION_ID);
+        if (processCorrelationId != null) {
+            outExchange.setProperty(JbiConstants.CORRELATION_ID, 
processCorrelationId);
+        }
         forwardToExchange(exchange, outExchange, in);
     }
 
@@ -88,6 +93,10 @@
         DeliveryChannel channel = getDeliveryChannel();
         MessageExchangeFactory factory = channel.createExchangeFactory(name);
         InOnly outExchange = factory.createInOnlyExchange();
+        String processCorrelationId = 
(String)exchange.getProperty(JbiConstants.CORRELATION_ID);
+        if (processCorrelationId != null) {
+            outExchange.setProperty(JbiConstants.CORRELATION_ID, 
processCorrelationId);
+        }
         forwardToExchange(exchange, outExchange, in);
     }