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!"); + } } }