You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cxf.apache.org by dk...@apache.org on 2008/07/17 20:29:14 UTC

svn commit: r677672 - /cxf/trunk/benchmark/performance/soap_http_doc_lit/src/org/apache/cxf/performance/complex_type/client/Client.java

Author: dkulp
Date: Thu Jul 17 11:29:13 2008
New Revision: 677672

URL: http://svn.apache.org/viewvc?rev=677672&view=rev
Log:
Experimenting with some chunking stuff

Modified:
    cxf/trunk/benchmark/performance/soap_http_doc_lit/src/org/apache/cxf/performance/complex_type/client/Client.java

Modified: cxf/trunk/benchmark/performance/soap_http_doc_lit/src/org/apache/cxf/performance/complex_type/client/Client.java
URL: http://svn.apache.org/viewvc/cxf/trunk/benchmark/performance/soap_http_doc_lit/src/org/apache/cxf/performance/complex_type/client/Client.java?rev=677672&r1=677671&r2=677672&view=diff
==============================================================================
--- cxf/trunk/benchmark/performance/soap_http_doc_lit/src/org/apache/cxf/performance/complex_type/client/Client.java (original)
+++ cxf/trunk/benchmark/performance/soap_http_doc_lit/src/org/apache/cxf/performance/complex_type/client/Client.java Thu Jul 17 11:29:13 2008
@@ -31,6 +31,11 @@
 import javax.xml.datatype.DatatypeFactory;
 import javax.xml.namespace.QName;
 
+
+import org.apache.cxf.frontend.ClientProxy;
+import org.apache.cxf.transport.http.HTTPConduit;
+import org.apache.cxf.transports.http.configuration.HTTPClientPolicy;
+  
 import org.apache.cxf.pat.internal.TestCaseBase;
 import org.apache.cxf.pat.internal.TestResult;
 import org.apache.cxf.cxf.performance.DocPortType;
@@ -243,7 +248,17 @@
         } catch (MalformedURLException e) {
             e.printStackTrace();
         }
-        return cs.getSoapHttpDocLitPort();
+        DocPortType port = cs.getSoapHttpDocLitPort();
+        
+        org.apache.cxf.endpoint.Client client = ClientProxy.getClient(port);
+        HTTPConduit http = (HTTPConduit) client.getConduit();
+
+        HTTPClientPolicy httpClientPolicy = new HTTPClientPolicy();
+        //httpClientPolicy.setAllowChunking(false);
+  
+        http.setClient(httpClientPolicy);
+  
+        return port;
     }
 
     public void printUsage() {