You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@uima.apache.org by de...@apache.org on 2015/02/05 19:06:54 UTC
svn commit: r1657648 -
/uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jd/JobDriverConfiguration.java
Author: degenaro
Date: Thu Feb 5 18:06:53 2015
New Revision: 1657648
URL: http://svn.apache.org/r1657648
Log:
UIMA-4069 DUCC Job Driver (JD) system classpath
when JD throws exception Agent should report process as Failed
Modified:
uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jd/JobDriverConfiguration.java
Modified: uima/sandbox/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/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jd/JobDriverConfiguration.java?rev=1657648&r1=1657647&r2=1657648&view=diff
==============================================================================
--- uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jd/JobDriverConfiguration.java (original)
+++ uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jd/JobDriverConfiguration.java Thu Feb 5 18:06:53 2015
@@ -206,32 +206,41 @@ import org.springframework.context.annot
@Bean
public JobDriverComponent jobDriver() throws Exception {
String location = "jobDriver";
- JobDriverComponent jdc = new JobDriverComponent("JobDriver", common.camelContext(), this);
- // Instantiate delegate listener to receive incoming messages.
- JobDriverEventListener delegateListener = this.jobDriverDelegateListener(jdc);
- // Inject a dispatcher into the listener in case it needs to send
- // a message to another component
- delegateListener.setDuccEventDispatcher(jobDriverTransport.duccEventDispatcher(common.orchestratorStateUpdateEndpoint, jdc.getContext()));
- // Inject Camel Router that will delegate messages to JobDriver delegate listener
- jdc.getContext().addRoutes(this.routeBuilderForIncomingRequests(common.orchestratorAbbreviatedStateUpdateEndpoint, delegateListener));
try {
- NodeIdentity nodeIdentity = new NodeIdentity();
- jdc.setNode(nodeIdentity.getIp());
+ JobDriverComponent jdc = new JobDriverComponent("JobDriver", common.camelContext(), this);
+ // Instantiate delegate listener to receive incoming messages.
+ JobDriverEventListener delegateListener = this.jobDriverDelegateListener(jdc);
+ // Inject a dispatcher into the listener in case it needs to send
+ // a message to another component
+ delegateListener.setDuccEventDispatcher(jobDriverTransport.duccEventDispatcher(common.orchestratorStateUpdateEndpoint, jdc.getContext()));
+ // Inject Camel Router that will delegate messages to JobDriver delegate listener
+ jdc.getContext().addRoutes(this.routeBuilderForIncomingRequests(common.orchestratorAbbreviatedStateUpdateEndpoint, delegateListener));
+ try {
+ NodeIdentity nodeIdentity = new NodeIdentity();
+ jdc.setNode(nodeIdentity.getIp());
+ }
+ catch(Exception e) {
+ logger.error(location, jobid, e);
+ }
+ port = Utils.findFreePort();
+ jdc.setPort(port);
+ String jdUniqueId = "/jdApp";
+// jdc.getContext().addRoutes(this.routeBuilderForJpIncomingRequests(jdc, port, jdUniqueId));
+ Server server = createServer(port, jdUniqueId, jdc);
+ server.start();
+ logger.info(location,jobid,"Jetty Running - Port:"+port);
+ logger.info(location, jobid, "port: "+port+" "+"endpoint: "+common.jdStateUpdateEndpoint+" "+"rate: "+common.jdStatePublishRate);
+
+ jdc.getContext().addRoutes(this.routeBuilderForJdStatePost(jdc, common.jdStateUpdateEndpoint, Integer.parseInt(common.jdStatePublishRate)));
+ return jdc;
}
catch(Exception e) {
logger.error(location, jobid, e);
+ int code = 55;
+ logger.warn(location, jobid, "halt code="+code);
+ Runtime.getRuntime().halt(code);
+ throw e;
}
- port = Utils.findFreePort();
- jdc.setPort(port);
- String jdUniqueId = "/jdApp";
-// jdc.getContext().addRoutes(this.routeBuilderForJpIncomingRequests(jdc, port, jdUniqueId));
- Server server = createServer(port, jdUniqueId, jdc);
- server.start();
- logger.info(location,jobid,"Jetty Running - Port:"+port);
- logger.info(location, jobid, "port: "+port+" "+"endpoint: "+common.jdStateUpdateEndpoint+" "+"rate: "+common.jdStatePublishRate);
-
- jdc.getContext().addRoutes(this.routeBuilderForJdStatePost(jdc, common.jdStateUpdateEndpoint, Integer.parseInt(common.jdStatePublishRate)));
- return jdc;
}
public class JDServlet extends HttpServlet
{