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
