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 2017/06/20 15:09:33 UTC
svn commit: r1799351 -
/uima/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jd/JobDriverConfiguration.java
Author: cwiklik
Date: Tue Jun 20 15:09:32 2017
New Revision: 1799351
URL: http://svn.apache.org/viewvc?rev=1799351&view=rev
Log:
UIMA-5404 refactored to send state update from within initialize() and running()
Modified:
uima/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jd/JobDriverConfiguration.java
Modified: uima/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jd/JobDriverConfiguration.java
URL: http://svn.apache.org/viewvc/uima/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jd/JobDriverConfiguration.java?rev=1799351&r1=1799350&r2=1799351&view=diff
==============================================================================
--- uima/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jd/JobDriverConfiguration.java (original)
+++ uima/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jd/JobDriverConfiguration.java Tue Jun 20 15:09:32 2017
@@ -185,8 +185,7 @@ import org.springframework.context.annot
// changes.
ProcessStateDispatcher stateNotifier =
new ProcessStateDispatcher();
- initializing();
- stateNotifier.sendStateUpdate(ProcessState.Initializing.name());
+ initializing(stateNotifier);
JobDriverComponent jdc = new JobDriverComponent("JobDriver", common.camelContext(), this);
// Instantiate delegate listener to receive incoming messages.
@@ -207,8 +206,7 @@ import org.springframework.context.annot
Server server = createServer(port, jdUniqueId, jdc);
server.start();
logger.info(location,jobid,"Jetty Started - Port: "+port);
- running();
- stateNotifier.sendStateUpdate(ProcessState.Running.name());
+ running(stateNotifier);
return jdc;
}
@@ -221,15 +219,17 @@ import org.springframework.context.annot
}
}
- private void initializing() {
+ private void initializing(ProcessStateDispatcher stateNotifier) throws Exception{
String location = "initializing";
String args = "";
+ stateNotifier.sendStateUpdate(ProcessState.Initializing.name());
logger.info(location, jobid, args);
}
- private void running() {
+ private void running(ProcessStateDispatcher stateNotifier) throws Exception {
String location = "running";
String args = "";
+ stateNotifier.sendStateUpdate(ProcessState.Running.name());
logger.info(location, jobid, args);
}