You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@camel.apache.org by da...@apache.org on 2011/09/21 17:48:03 UTC

svn commit: r1173732 - /camel/trunk/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/HazelcastComponentHelper.java

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