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"); }