svn commit: r1167098 - /camel/trunk/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfProducer.java

[ni...@apache.org]

Author: ningjiang
Date: Fri Sep  9 11:15:40 2011
New Revision: 1167098

URL: http://svn.apache.org/viewvc?rev=1167098&view=rev
Log:
CAMEL-4429 CXFProducer should tell CXF to ignore the part response handling when it uses MESSSAGE data format

Modified:
    camel/trunk/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfProducer.java

Modified: camel/trunk/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfProducer.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfProducer.java?rev=1167098&r1=1167097&r2=1167098&view=diff
==============================================================================
--- camel/trunk/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfProducer.java (original)
+++ camel/trunk/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfProducer.java Fri Sep  9 11:15:40 2011
@@ -128,6 +128,7 @@ public class CxfProducer extends Default
             // send the CXF request
             client.invoke(boi, getParams(endpoint, camelExchange), 
                       invocationContext, cxfExchange);
+
         } catch (Exception exception) {
             camelExchange.setException(exception);
         } finally {
@@ -161,6 +162,8 @@ public class CxfProducer extends Default
         if (dataFormat == DataFormat.MESSAGE) {
             cxfExchange.put(Client.KEEP_CONDUIT_ALIVE, true);
             LOG.trace("Set CXF Exchange property: {}={}", Client.KEEP_CONDUIT_ALIVE, true);
+            // Ignore the partical response message handling
+            requestContext.put("org.apache.cxf.partial.response.handling", Boolean.FALSE);
         }
      
         // bind the request CXF exchange