svn commit: r673955 - /activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/ConvertBodyProcessor.java

[jstrachan]

Author: jstrachan
Date: Fri Jul  4 01:30:54 2008
New Revision: 673955

URL: http://svn.apache.org/viewvc?rev=673955&view=rev
Log:
a more strict ConvertBodyProcessor which respects the MEP

Modified:
    
activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/ConvertBodyProcessor.java

Modified: 
activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/ConvertBodyProcessor.java
URL: 
http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/ConvertBodyProcessor.java?rev=673955&r1=673954&r2=673955&view=diff
==============================================================================
--- 
activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/ConvertBodyProcessor.java
 (original)
+++ 
activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/ConvertBodyProcessor.java
 Fri Jul  4 01:30:54 2008
@@ -19,6 +19,7 @@
 import org.apache.camel.Exchange;
 import org.apache.camel.Message;
 import org.apache.camel.Processor;
+import org.apache.camel.util.ExchangeHelper;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 
@@ -41,8 +42,13 @@
         if (value == null) {
             LOG.warn("Could not convert body of IN message: " + in + " to 
type: " + type.getName());
         }
-        Message out = exchange.getOut();
-        out.copyFrom(in);
-        out.setBody(value);
+        if (exchange.getPattern().isOutCapable()) {
+            Message out = exchange.getOut();
+            out.copyFrom(in);
+            out.setBody(value);
+        }
+        else {
+            in.setBody(value);
+        }
     }
 }