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() {