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

[cwiklik]

Author: cwiklik
Date: Fri Jul 31 17:26:45 2015
New Revision: 1693634

URL: http://svn.apache.org/r1693634
Log:
UIMA-4540 clear pipeline elements (containing init info) when transitioning 
from Initializing to Running state

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=1693634&r1=1693633&r2=1693634&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
 Fri Jul 31 17:26:45 2015
@@ -1020,7 +1020,15 @@ public class NodeAgent extends AbstractD
                     deployedProcess);
             super.getContext().addRoutes(rb);
             StringBuffer sb = new StringBuffer();
-            
+            if ( duccEvent.getState().equals(ProcessState.Running) ) {
+               if ( processEntry.getValue().getUimaPipelineComponents() != 
null && 
+                       
processEntry.getValue().getUimaPipelineComponents().size() > 0 ) {
+                  processEntry.getValue().getUimaPipelineComponents().clear();
+                  if ( duccEvent.getUimaPipeline() != null ) {
+                          duccEvent.getUimaPipeline().clear();
+                  }
+               }
+            }
             for ( Route route : super.getContext().getRoutes() ) {
                sb.append("Camel Context - RouteId:"+route.getId()+"\n");
             }