You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@servicemix.apache.org by ff...@apache.org on 2008/09/02 11:27:08 UTC
svn commit: r691173 -
/servicemix/smx3/branches/servicemix-3.2/deployables/serviceengines/servicemix-camel/src/main/java/org/apache/servicemix/camel/JbiBinding.java
Author: ffang
Date: Tue Sep 2 02:27:07 2008
New Revision: 691173
URL: http://svn.apache.org/viewvc?rev=691173&view=rev
Log:
[SM-1540]servicemix-camel component should check if property value is serializable before copy it from camel exchange to servicemix exchange
Modified:
servicemix/smx3/branches/servicemix-3.2/deployables/serviceengines/servicemix-camel/src/main/java/org/apache/servicemix/camel/JbiBinding.java
Modified: servicemix/smx3/branches/servicemix-3.2/deployables/serviceengines/servicemix-camel/src/main/java/org/apache/servicemix/camel/JbiBinding.java
URL: http://svn.apache.org/viewvc/servicemix/smx3/branches/servicemix-3.2/deployables/serviceengines/servicemix-camel/src/main/java/org/apache/servicemix/camel/JbiBinding.java?rev=691173&r1=691172&r2=691173&view=diff
==============================================================================
--- servicemix/smx3/branches/servicemix-3.2/deployables/serviceengines/servicemix-camel/src/main/java/org/apache/servicemix/camel/JbiBinding.java (original)
+++ servicemix/smx3/branches/servicemix-3.2/deployables/serviceengines/servicemix-camel/src/main/java/org/apache/servicemix/camel/JbiBinding.java Tue Sep 2 02:27:07 2008
@@ -16,6 +16,7 @@
*/
package org.apache.servicemix.camel;
+import java.io.Serializable;
import java.io.StringReader;
import java.net.URI;
import java.net.URISyntaxException;
@@ -153,7 +154,9 @@
protected void addJbiHeaders(MessageExchange jbiExchange, NormalizedMessage normalizedMessage, Exchange camelExchange) {
Set<Map.Entry<String, Object>> entries = camelExchange.getIn().getHeaders().entrySet();
for (Map.Entry<String, Object> entry : entries) {
- normalizedMessage.setProperty(entry.getKey(), entry.getValue());
+ if (entry.getValue() instanceof Serializable) {
+ normalizedMessage.setProperty(entry.getKey(), entry.getValue());
+ }
}
}