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 2019/03/08 17:51:29 UTC
svn commit: r1855058 -
/uima/uima-ducc/trunk/uima-ducc-pullservice/src/main/java/org/apache/uima/ducc/ps/service/transport/http/HttpServiceTransport.java
Author: cwiklik
Date: Fri Mar 8 17:51:29 2019
New Revision: 1855058
URL: http://svn.apache.org/viewvc?rev=1855058&view=rev
Log:
UIMA-5996 allow transport to deliver msgs while in stopping state
Modified:
uima/uima-ducc/trunk/uima-ducc-pullservice/src/main/java/org/apache/uima/ducc/ps/service/transport/http/HttpServiceTransport.java
Modified: uima/uima-ducc/trunk/uima-ducc-pullservice/src/main/java/org/apache/uima/ducc/ps/service/transport/http/HttpServiceTransport.java
URL: http://svn.apache.org/viewvc/uima/uima-ducc/trunk/uima-ducc-pullservice/src/main/java/org/apache/uima/ducc/ps/service/transport/http/HttpServiceTransport.java?rev=1855058&r1=1855057&r2=1855058&view=diff
==============================================================================
--- uima/uima-ducc/trunk/uima-ducc-pullservice/src/main/java/org/apache/uima/ducc/ps/service/transport/http/HttpServiceTransport.java (original)
+++ uima/uima-ducc/trunk/uima-ducc-pullservice/src/main/java/org/apache/uima/ducc/ps/service/transport/http/HttpServiceTransport.java Fri Mar 8 17:51:29 2019
@@ -236,9 +236,9 @@ public class HttpServiceTransport implem
IMetaTaskTransaction metaTransaction=null;
HttpResponse response = httpClient.execute(postMethod);
- if ( stopping ) {
- throw new TransportException("Service stopping - rejecting request");
- }
+ // if ( stopping ) {
+ // throw new TransportException("Service stopping - rejecting request");
+ //}
HttpEntity entity = response.getEntity();
String serializedResponse = EntityUtils.toString(entity);
Object transaction=null;
@@ -276,9 +276,9 @@ public class HttpServiceTransport implem
*/
@Override
public synchronized IMetaTaskTransaction dispatch(String serializedRequest) throws TransportException {
- if ( stopping ) {
- throw new IllegalStateException("Service transport has been stopped, unable to dispatch request");
- }
+ //if ( stopping ) {
+ // throw new IllegalStateException("Service transport has been stopped, unable to dispatch request");
+ // }
IMetaTaskTransaction transaction=null;
HttpEntity e = wrapRequest(serializedRequest);
// Each thread has its own HttpPost method. If current thread