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 2018/05/03 17:50:35 UTC
svn commit: r1830850 -
/uima/uima-ducc/trunk/uima-ducc-pullservice/src/main/java/org/apache/uima/ducc/ps/service/main/PullService.java
Author: cwiklik
Date: Thu May 3 17:50:34 2018
New Revision: 1830850
URL: http://svn.apache.org/viewvc?rev=1830850&view=rev
Log:
UIMA-5756 added no task strategy
Modified:
uima/uima-ducc/trunk/uima-ducc-pullservice/src/main/java/org/apache/uima/ducc/ps/service/main/PullService.java
Modified: uima/uima-ducc/trunk/uima-ducc-pullservice/src/main/java/org/apache/uima/ducc/ps/service/main/PullService.java
URL: http://svn.apache.org/viewvc/uima/uima-ducc/trunk/uima-ducc-pullservice/src/main/java/org/apache/uima/ducc/ps/service/main/PullService.java?rev=1830850&r1=1830849&r2=1830850&view=diff
==============================================================================
--- uima/uima-ducc/trunk/uima-ducc-pullservice/src/main/java/org/apache/uima/ducc/ps/service/main/PullService.java (original)
+++ uima/uima-ducc/trunk/uima-ducc-pullservice/src/main/java/org/apache/uima/ducc/ps/service/main/PullService.java Thu May 3 17:50:34 2018
@@ -41,6 +41,7 @@ import org.apache.uima.ducc.ps.service.m
import org.apache.uima.ducc.ps.service.processor.IServiceProcessor;
import org.apache.uima.ducc.ps.service.protocol.IServiceProtocolHandler;
import org.apache.uima.ducc.ps.service.protocol.builtin.DefaultServiceProtocolHandler;
+import org.apache.uima.ducc.ps.service.protocol.builtin.NoWaitStrategy;
import org.apache.uima.ducc.ps.service.registry.DefaultRegistryClient;
import org.apache.uima.ducc.ps.service.registry.IRegistryClient;
import org.apache.uima.ducc.ps.service.transport.IServiceTransport;
@@ -134,6 +135,7 @@ public class PullService implements ISer
registryClient = new DefaultRegistryClient(target);
}
+
@Override
public void initialize() throws ServiceInitializationException {
// only one thread can call this method
@@ -172,6 +174,7 @@ public class PullService implements ISer
protocolHandler =
new DefaultServiceProtocolHandler.Builder()
.withProcessor(serviceProcessor)
+ .withNoTaskStrategy(new NoWaitStrategy())
.withService(this)
.withTransport(transport)
.withDoneLatch(stopLatch)