Author: cwiklik
Date: Thu Jan 28 18:44:16 2016
New Revision: 1727418

URL: http://svn.apache.org/viewvc?rev=1727418&view=rev
Log:
UIMA-4773 Refactored Agent and JP to use SIGTERM signal to quiesce and stop JP

Modified:
    
uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jp/JobProcessConfiguration.java

Modified: 
uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jp/JobProcessConfiguration.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/JobProcessConfiguration.java?rev=1727418&r1=1727417&r2=1727418&view=diff
==============================================================================
--- 
uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jp/JobProcessConfiguration.java
 (original)
+++ 
uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jp/JobProcessConfiguration.java
 Thu Jan 28 18:44:16 2016
@@ -62,6 +62,7 @@ public class JobProcessConfiguration {
         * 
         * @return {@code RouteBuilder} instance
         */
+    /*
        public synchronized RouteBuilder routeBuilderForIncomingRequests(
                        final String thisNodeIP, final JobProcessEventListener 
delegate) {
                return new RouteBuilder() {
@@ -95,7 +96,7 @@ public class JobProcessConfiguration {
                        caused.printStackTrace();
                }
        }
-
+    */
        private void checkPrereqs() {
                boolean uimaAsJob = false;
 
@@ -265,13 +266,14 @@ public class JobProcessConfiguration {
                             "Overriding Default Process Request Timeout - New 
Timeout "+common.processRequestTimeout+" ms");
                        }
 
+                       /*
                        JobProcessEventListener eventListener = new 
JobProcessEventListener(
                                        duccComponent);
                        routeBuilder = 
this.routeBuilderForIncomingRequests(thisNodeIP,
                                        eventListener);
 
                        camelContext.addRoutes(routeBuilder);
-
+                       */
                        return duccComponent;
 
                } catch (Exception e) {


Reply via email to