You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ni...@apache.org on 2009/09/04 15:50:34 UTC

svn commit: r811405 - /camel/branches/camel-1.x/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfExchange.java

Author: ningjiang
Date: Fri Sep  4 13:50:34 2009
New Revision: 811405

URL: http://svn.apache.org/viewvc?rev=811405&view=rev
Log:
CAMEL-1983 fixed the test error of LoadBrokerTest.testInvocation which is caused by last commit, copying the underlayer CXF message only

Modified:
    camel/branches/camel-1.x/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfExchange.java

Modified: camel/branches/camel-1.x/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfExchange.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-1.x/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfExchange.java?rev=811405&r1=811404&r2=811405&view=diff
==============================================================================
--- camel/branches/camel-1.x/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfExchange.java (original)
+++ camel/branches/camel-1.x/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfExchange.java Fri Sep  4 13:50:34 2009
@@ -64,19 +64,21 @@
             return;
         }
         
-        org.apache.camel.Message message = exchange.getIn();
+        // Just make sure the wrapped CXF message be copied
+        
+        CxfMessage message = (CxfMessage)exchange.getIn();
         if (message != null) {
-            this.setIn(message);
+            this.setIn(new CxfMessage(message.getMessage()));
         }
         
-        message = exchange.getOut(false);
+        message = (CxfMessage) exchange.getOut(false);
         if (message != null) {
-            this.setOut(message);
+            this.setOut(new CxfMessage(message.getMessage()));
         }
         
-        message = exchange.getFault(false);
+        message = (CxfMessage) exchange.getFault(false);
         if (message != null) {
-            this.setFault(message);
+            this.setFault(new CxfMessage(message.getMessage()));
         }
         
     }