[jbossws-commits] JBossWS SVN: r13246 - in stack/native/trunk/modules/core/src/main/java/org/jboss/ws/core/client: transport and 1 other directory.
Author: richard.opalka(a)jboss.com
Date: 2010-11-09 04:59:55 -0500 (Tue, 09 Nov 2010)
New Revision: 13246
Modified:
stack/native/trunk/modules/core/src/main/java/org/jboss/ws/core/client/HTTPRemotingConnection.java
stack/native/trunk/modules/core/src/main/java/org/jboss/ws/core/client/transport/NettyClient.java
Log:
[JBWS-3084] implemented chunking customization feature on top of SAAJ
Modified:
stack/native/trunk/modules/core/src/main/java/org/jboss/ws/core/client/HTTPRemotingConnection.java
===================================================================
---
stack/native/trunk/modules/core/src/main/java/org/jboss/ws/core/client/HTTPRemotingConnection.java 2010-11-09
09:48:24 UTC (rev 13245)
+++
stack/native/trunk/modules/core/src/main/java/org/jboss/ws/core/client/HTTPRemotingConnection.java 2010-11-09
09:59:55 UTC (rev 13246)
@@ -33,6 +33,7 @@
import org.jboss.logging.Logger;
import org.jboss.ws.core.MessageAbstraction;
import org.jboss.ws.core.MessageTrace;
+import org.jboss.ws.core.StubExt;
import org.jboss.ws.core.client.transport.NettyClient;
import org.jboss.ws.extensions.wsrm.transport.RMChannel;
import org.jboss.ws.extensions.wsrm.transport.RMMetadata;
@@ -118,6 +119,12 @@
{
targetAddress = endpoint.toString();
}
+ final String[] transferEncodingValue = reqMessage != null ?
reqMessage.getMimeHeaders().getHeader("Transfer-Encoding") : null;
+ if (transferEncodingValue != null &&
"disabled".equals(transferEncodingValue[0]))
+ {
+ reqMessage.getMimeHeaders().removeHeader("Transfer-Encoding");
+ callProps.put(StubExt.PROPERTY_CHUNKED_ENCODING_SIZE, 0);
+ }
if (RMTransportHelper.isRMMessage(callProps))
{
Modified:
stack/native/trunk/modules/core/src/main/java/org/jboss/ws/core/client/transport/NettyClient.java
===================================================================
---
stack/native/trunk/modules/core/src/main/java/org/jboss/ws/core/client/transport/NettyClient.java 2010-11-09
09:48:24 UTC (rev 13245)
+++
stack/native/trunk/modules/core/src/main/java/org/jboss/ws/core/client/transport/NettyClient.java 2010-11-09
09:59:55 UTC (rev 13246)
@@ -354,22 +354,21 @@
if (sizeValue != null)
chunkSize = Integer.valueOf(sizeValue);
- //override using call props
- try
- {
- Object obj = callProps.get(StubExt.PROPERTY_CHUNKED_ENCODING_SIZE);
- if (obj != null) //explicit 0 value is required to disable chunked mode
- chunkSize = (Integer)obj;
- }
- catch (Exception e)
- {
- log.warn("Can't set chunk size from call properties, illegal
value provided!");
- }
-
//fastinfoset always disable chunking
if (epMetaData.isFeatureEnabled(FastInfosetFeature.class))
chunkSize = 0;
}
+ //override using call props
+ try
+ {
+ Object obj = callProps.get(StubExt.PROPERTY_CHUNKED_ENCODING_SIZE);
+ if (obj != null) //explicit 0 value is required to disable chunked mode
+ chunkSize = (Integer)obj;
+ }
+ catch (Exception e)
+ {
+ log.warn("Can't set chunk size from call properties, illegal value
provided!");
+ }
}
}