svn commit: r1781011 - /uima/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jp/JobProcessComponent.java

[cwiklik]

Author: cwiklik
Date: Tue Jan 31 01:53:41 2017
New Revision: 1781011

URL: http://svn.apache.org/viewvc?rev=1781011&view=rev
Log:
UIMA-5284 Modified to send FailedInitialization to an agent

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

Modified: 
uima/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jp/JobProcessComponent.java
URL: 
http://svn.apache.org/viewvc/uima/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jp/JobProcessComponent.java?rev=1781011&r1=1781010&r2=1781011&view=diff
==============================================================================
--- 
uima/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jp/JobProcessComponent.java
 (original)
+++ 
uima/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jp/JobProcessComponent.java
 Tue Jan 31 01:53:41 2017
@@ -99,9 +99,17 @@ implements IJobProcessor{
                        if ( message == null ) {
                                message = super.getProcessJmxUrl();
                        }
+                       
                        if ( !state.name().equals(currentState.name())) {
-                               currentState = state;
-                               logger.info("setState", null, "Notifying Agent 
New State:"+state.name());
+                               if ( state.equals(ProcessState.Stopping) && 
+                                               
(currentState.equals(ProcessState.Initializing ) ||
+                                                
currentState.equals(ProcessState.Undefined ) ||
+                                                
currentState.equals(ProcessState.Starting ) ) ) {
+                                       currentState = 
ProcessState.FailedInitialization;
+                               } else {
+                                       currentState = state;
+                               }
+                               logger.info("setState", null, "Notifying Agent 
New State::::"+currentState.name());
                                if ( agent != null ) {
                                        agent.notify(currentState, message);
                                }