[jbossws-commits] JBossWS SVN: r13246 - in stack/native/trunk/modules/core/src/main/java/org/jboss/ws/core/client: transport and 1 other directory.

[jbossws-commits at lists.jboss.org]

Author: richard.opalka at 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!");
+         }
       }
    }