Author: dkulp
Date: Mon Oct 17 14:22:02 2011
New Revision: 1185193
URL: http://svn.apache.org/viewvc?rev=1185193&view=rev
Log:
[CAMEL-4548] Allow controlling the allowStreaming from CxfComponent
Modified:
camel/trunk/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfComponent.java
camel/trunk/components/camel-cxf/src/test/java/org/apache/camel/component/cxf/CxfMixedModeRouterTest.java
Modified:
camel/trunk/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfComponent.java
URL:
http://svn.apache.org/viewvc/camel/trunk/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfComponent.java?rev=1185193&r1=1185192&r2=1185193&view=diff
==============================================================================
---
camel/trunk/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfComponent.java
(original)
+++
camel/trunk/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfComponent.java
Mon Oct 17 14:22:02 2011
@@ -30,13 +30,21 @@ import org.apache.cxf.message.Message;
* Defines the <a href="http://camel.apache.org/cxf.html";>CXF Component</a>
*/
public class CxfComponent extends HeaderFilterStrategyComponent {
-
+ Boolean allowStreaming;
+
public CxfComponent() {
}
public CxfComponent(CamelContext context) {
super(context);
}
+
+ public void setAllowStreaming(Boolean b) {
+ allowStreaming = b;
+ }
+ public Boolean getAllowStreaming() {
+ return allowStreaming;
+ }
/**
* Create a {@link CxfEndpoint} which, can be a Spring bean endpoint having
@@ -47,6 +55,10 @@ public class CxfComponent extends Header
protected Endpoint createEndpoint(String uri, String remaining,
Map<String, Object> parameters) throws Exception {
CxfEndpoint result = null;
+
+ if (allowStreaming != null &&
!parameters.containsKey("allowStreaming")) {
+ parameters.put("allowStreaming", Boolean.toString(allowStreaming));
+ }
if (remaining.startsWith(CxfConstants.SPRING_CONTEXT_ENDPOINT)) {
// Get the bean from the Spring context
Modified:
camel/trunk/components/camel-cxf/src/test/java/org/apache/camel/component/cxf/CxfMixedModeRouterTest.java
URL:
http://svn.apache.org/viewvc/camel/trunk/components/camel-cxf/src/test/java/org/apache/camel/component/cxf/CxfMixedModeRouterTest.java?rev=1185193&r1=1185192&r2=1185193&view=diff
==============================================================================
---
camel/trunk/components/camel-cxf/src/test/java/org/apache/camel/component/cxf/CxfMixedModeRouterTest.java
(original)
+++
camel/trunk/components/camel-cxf/src/test/java/org/apache/camel/component/cxf/CxfMixedModeRouterTest.java
Mon Oct 17 14:22:02 2011
@@ -54,7 +54,7 @@ public class CxfMixedModeRouterTest exte
protected static final String SERVICE_ADDRESS = "http://localhost:"; +
port2 + "/CxfMixedModeRouterTest/helloworld";
protected static final String SERVICE_CLASS =
"serviceClass=org.apache.camel.component.cxf.HelloService";
- private String routerEndpointURI = "cxf://" + ROUTER_ADDRESS + "?" +
SERVICE_CLASS + "&dataFormat=PAYLOAD";
+ private String routerEndpointURI = "cxf://" + ROUTER_ADDRESS + "?" +
SERVICE_CLASS + "&dataFormat=PAYLOAD&allowStreaming=false";
private String serviceEndpointURI = "cxf://" + SERVICE_ADDRESS + "?" +
SERVICE_CLASS + "&dataFormat=POJO";
@Override
public boolean isCreateCamelContextPerClass() {
