svn commit: r1728548 - /uima/sandbox/uima-ducc/trunk/uima-ducc-agent/src/main/java/org/apache/uima/ducc/agent/NodeAgent.java

[cwiklik]

Author: cwiklik
Date: Thu Feb  4 19:57:30 2016
New Revision: 1728548

URL: http://svn.apache.org/viewvc?rev=1728548&view=rev
Log:
UIMA-4787 Fixed child process route not starting problem

Modified:
    
uima/sandbox/uima-ducc/trunk/uima-ducc-agent/src/main/java/org/apache/uima/ducc/agent/NodeAgent.java

Modified: 
uima/sandbox/uima-ducc/trunk/uima-ducc-agent/src/main/java/org/apache/uima/ducc/agent/NodeAgent.java
URL: 
http://svn.apache.org/viewvc/uima/sandbox/uima-ducc/trunk/uima-ducc-agent/src/main/java/org/apache/uima/ducc/agent/NodeAgent.java?rev=1728548&r1=1728547&r2=1728548&view=diff
==============================================================================
--- 
uima/sandbox/uima-ducc/trunk/uima-ducc-agent/src/main/java/org/apache/uima/ducc/agent/NodeAgent.java
 (original)
+++ 
uima/sandbox/uima-ducc/trunk/uima-ducc-agent/src/main/java/org/apache/uima/ducc/agent/NodeAgent.java
 Thu Feb  4 19:57:30 2016
@@ -1042,6 +1042,14 @@ public class NodeAgent extends AbstractD
             RouteBuilder rb = new ProcessMemoryUsageRoute(this, 
processEntry.getValue(),
                     deployedProcess);
             super.getContext().addRoutes(rb);
+           //super.getContext().start();
+           super.getContext().startRoute(duccEvent.getPid());
+            logger.info(
+                    methodName,
+                    null,
+                    "Started Process Metric Gathering Thread For 
PID:"+duccEvent.getPid());
+
+
             StringBuffer sb = new StringBuffer();
             if ( duccEvent.getState().equals(ProcessState.Running) ) {
                if ( processEntry.getValue().getUimaPipelineComponents() != 
null && 
@@ -1559,7 +1567,9 @@ public class NodeAgent extends AbstractD
 
     public void configure() throws Exception {
       Processor nmp = configurationFactory.processMetricsProcessor(agent, 
process, managedProcess);
-      from("timer:processMemPollingTimer?fixedRate=true&period=" + 
5000).routeId(process.getPID())
+      int fixedRate = configurationFactory.getNodeInventoryPublishDelay();
+      from("timer:processMemPollingTimer?fixedRate=true&delay=100&period=" + 
fixedRate).routeId(process.getPID())
+              .autoStartup(true)
               .process(nmp);
     }
   }