camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject svn commit: r1173732 - /camel/trunk/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/HazelcastComponentHelper.java
Date Wed, 21 Sep 2011 15:48:03 GMT
Author: davsclaus
Date: Wed Sep 21 15:48:03 2011
New Revision: 1173732

URL: http://svn.apache.org/viewvc?rev=1173732&view=rev
Log:
CAMEL-4472: Fixed preserve headers for hazelcast producer. Thanks to Tomislav for the patch.

Modified:
    camel/trunk/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/HazelcastComponentHelper.java

Modified: camel/trunk/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/HazelcastComponentHelper.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/HazelcastComponentHelper.java?rev=1173732&r1=1173731&r2=1173732&view=diff
==============================================================================
--- camel/trunk/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/HazelcastComponentHelper.java
(original)
+++ camel/trunk/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/HazelcastComponentHelper.java
Wed Sep 21 15:48:03 2011
@@ -43,8 +43,10 @@ public class HazelcastComponentHelper {
             headers.remove(HazelcastConstants.OPERATION);
         }
 
-        // set out headers
-        ex.getOut().setHeaders(headers);
+        // propagate headers if OUT message created
+        if (ex.hasOut()) {
+            ex.getOut().setHeaders(headers);
+        }
     }
 
     public static void setListenerHeaders(Exchange ex, String listenerType, String listenerAction,
String cacheName) {



Mime
View raw message