Author: heiko.braun(a)jboss.com
Date: 2007-05-18 11:29:32 -0400 (Fri, 18 May 2007)
New Revision: 3143
Modified:
branches/jbossws-2.0/jbossws-core/src/java/org/jboss/ws/core/client/RemotingConnectionImpl.java
Log:
Enforce chunked encoding
Modified:
branches/jbossws-2.0/jbossws-core/src/java/org/jboss/ws/core/client/RemotingConnectionImpl.java
===================================================================
---
branches/jbossws-2.0/jbossws-core/src/java/org/jboss/ws/core/client/RemotingConnectionImpl.java 2007-05-18
14:15:13 UTC (rev 3142)
+++
branches/jbossws-2.0/jbossws-core/src/java/org/jboss/ws/core/client/RemotingConnectionImpl.java 2007-05-18
15:29:32 UTC (rev 3143)
@@ -33,6 +33,7 @@
import org.jboss.ws.core.MessageTrace;
import org.jboss.ws.core.StubExt;
import org.jboss.ws.core.WSTimeoutException;
+import org.jboss.ws.metadata.config.EndpointProperty;
import javax.xml.rpc.Stub;
import javax.xml.soap.MimeHeader;
@@ -96,6 +97,10 @@
// HTTPClientInvoker conect sends gratuitous POST
//
http://jira.jboss.com/jira/browse/JBWS-711
clientConfig.put(Client.ENABLE_LEASE, false);
+
+ // Enable chunked encoding
+ // TODO: make this configurable through an endoint property
+ clientConfig.put("chunkedLength", "2048");
}
public boolean isClosed()
@@ -135,8 +140,7 @@
{
timeout = callProps.get(StubExt.PROPERTY_CLIENT_TIMEOUT);
targetAddress = addURLParameter(targetAddress, "timeout",
timeout.toString());
- }
-
+ }
}
else if (endpoint instanceof EndpointReference)
{
@@ -150,7 +154,7 @@
// setup remoting client
Map<String, Object> metadata = createRemotingMetaData(reqMessage,
callProps);
- Client client = createRemotingClient(endpoint, targetAddress, oneway);
+ Client client = createRemotingClient(endpoint, targetAddress, oneway);
try
{
@@ -255,9 +259,6 @@
// metadata.put(HTTPMetadataConstants.NO_THROW_ON_ERROR, "true"); //
since 2.0.0.GA
metadata.put("NoThrowOnError", "true");
- // Chunked transfer encoding
- metadata.put("chunkedLength", "1024");
-
if (reqMessage != null)
{
populateHeaders(reqMessage, metadata);