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 2015/01/20 20:37:28 UTC
svn commit: r1653349 -
/uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configurator/jp/JobProcessComponent.java
Author: cwiklik
Date: Tue Jan 20 19:37:28 2015
New Revision: 1653349
URL: http://svn.apache.org/r1653349
Log:
UIMA-4066 minor code cleanup
Modified:
uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configurator/jp/JobProcessComponent.java
Modified: uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configurator/jp/JobProcessComponent.java
URL: http://svn.apache.org/viewvc/uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configurator/jp/JobProcessComponent.java?rev=1653349&r1=1653348&r2=1653349&view=diff
==============================================================================
--- uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configurator/jp/JobProcessComponent.java (original)
+++ uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configurator/jp/JobProcessComponent.java Tue Jan 20 19:37:28 2015
@@ -303,17 +303,9 @@ implements IJobProcessor{
return; // already stopping - nothing to do
}
- System.out.println("... AbstractManagedService - Stopping Service Adapter");
+ System.out.println("... JobProcessComponent - Stopping Service Adapter");
try {
-// if (getContext() != null) {
-// for (Route route : getContext().getRoutes()) {
-//
-// route.getConsumer().stop();
-// System.out.println(">>> configFactory.stop() - stopped route:"
-// + route.getId());
-// }
-// }
- // block for worker threads to exit run()
+ // block until all worker threads exit run()
workerThreadCount.await();
// Stop executor. It was only needed to poll AE initialization status.
@@ -329,14 +321,9 @@ implements IJobProcessor{
tpe.awaitTermination(0, TimeUnit.MILLISECONDS);
}
-// if ( uimaProcessor != null ) {
-// uimaProcessor.stop();
-// }
if ( agent != null) {
agent.stop();
}
-
-
} catch( Exception e) {
e.printStackTrace();
} finally {