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