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 2015/07/31 19:26:46 UTC
svn commit: r1693634 -
/uima/sandbox/uima-ducc/trunk/uima-ducc-agent/src/main/java/org/apache/uima/ducc/agent/NodeAgent.java
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");
}