You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@uima.apache.org by cw...@apache.org on 2014/12/12 20:11:08 UTC
svn commit: r1645038 -
/uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jp/DuccHttpClient.java
Author: cwiklik
Date: Fri Dec 12 19:11:08 2014
New Revision: 1645038
URL: http://svn.apache.org/r1645038
Log:
UIMA-4066 synchronized execute
Modified:
uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jp/DuccHttpClient.java
Modified: uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jp/DuccHttpClient.java
URL: http://svn.apache.org/viewvc/uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jp/DuccHttpClient.java?rev=1645038&r1=1645037&r2=1645038&view=diff
==============================================================================
--- uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jp/DuccHttpClient.java (original)
+++ uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jp/DuccHttpClient.java Fri Dec 12 19:11:08 2014
@@ -72,7 +72,7 @@ public class DuccHttpClient {
int timeout;
// New --------------------
- HttpClient httpClient = new HttpClient(new MultiThreadedHttpConnectionManager());
+ HttpClient httpClient = null;
PostMethod postMethod;
public void setTimeout( int timeout) {
@@ -87,6 +87,12 @@ public class DuccHttpClient {
postMethod = new PostMethod(jdUrl);
pid = getProcessIP("N/A");
nodeIdentity = new NodeIdentity();
+ MultiThreadedHttpConnectionManager cMgr =
+ new MultiThreadedHttpConnectionManager();
+
+ httpClient =
+ new HttpClient(cMgr);
+
}
public void intialize(String url, int port, String application)
throws Exception {
@@ -257,7 +263,7 @@ public class DuccHttpClient {
}
- public IMetaCasTransaction execute( IMetaCasTransaction transaction ) throws Exception {
+ public synchronized IMetaCasTransaction execute( IMetaCasTransaction transaction ) throws Exception {
int retry = 2;
Exception lastError = null;
IMetaCasTransaction reply=null;
@@ -273,7 +279,7 @@ public class DuccHttpClient {
RequestEntity e = new StringRequestEntity(body,"application/xml","UTF-8" );
postMethod.setRequestEntity(e);
System.out.println("Entity Body Length:"+postMethod.getRequestEntity().getContentLength());
- addCommonHeaders(postMethod);
+ //addCommonHeaders(postMethod);
postMethod.setRequestHeader("Content-Length", String.valueOf(body.length()));
// wait for a reply
httpClient.executeMethod(postMethod);