X-Git-Url: http://git.argeo.org/?a=blobdiff_plain;ds=sidebyside;f=runtime%2Forg.argeo.slc.core%2Fsrc%2Fmain%2Fjava%2Forg%2Fargeo%2Fslc%2Fcore%2Fexecution%2FAbstractExecutionModulesManager.java;h=06c05248b2f3c82ec3c25fa89c17ac719937e6d8;hb=3781dcd363f0f6265fae0ac758fd40cf4254ebc9;hp=4e9856fe6f2745bd0d2cc5ab2ffa42c51592b633;hpb=30f4c6af6c20077e5e36b61faf5edb22c1aae6c6;p=gpl%2Fargeo-slc.git diff --git a/runtime/org.argeo.slc.core/src/main/java/org/argeo/slc/core/execution/AbstractExecutionModulesManager.java b/runtime/org.argeo.slc.core/src/main/java/org/argeo/slc/core/execution/AbstractExecutionModulesManager.java index 4e9856fe6..06c05248b 100644 --- a/runtime/org.argeo.slc.core/src/main/java/org/argeo/slc/core/execution/AbstractExecutionModulesManager.java +++ b/runtime/org.argeo.slc.core/src/main/java/org/argeo/slc/core/execution/AbstractExecutionModulesManager.java @@ -26,21 +26,20 @@ import org.apache.commons.logging.LogFactory; import org.argeo.slc.execution.ExecutionContext; import org.argeo.slc.execution.ExecutionFlow; import org.argeo.slc.execution.ExecutionFlowDescriptorConverter; -import org.argeo.slc.execution.ExecutionModulesListener; import org.argeo.slc.execution.ExecutionModulesManager; +import org.argeo.slc.execution.ExecutionProcess; import org.argeo.slc.process.RealizedFlow; -import org.argeo.slc.process.SlcExecution; import org.argeo.slc.process.SlcExecutionNotifier; import org.argeo.slc.process.SlcExecutionStep; /** Provides the base feature of an execution module manager. */ +@SuppressWarnings("deprecation") public abstract class AbstractExecutionModulesManager implements ExecutionModulesManager { private final static Log log = LogFactory .getLog(AbstractExecutionModulesManager.class); private List slcExecutionNotifiers = new ArrayList(); - private List executionModulesListeners = new ArrayList(); private ThreadGroup processesThreadGroup = new ThreadGroup("Processes"); @@ -53,10 +52,6 @@ public abstract class AbstractExecutionModulesManager implements protected abstract ExecutionFlowDescriptorConverter getExecutionFlowDescriptorConverter( String moduleName, String moduleVersion); - public void process(SlcExecution slcExecution) { - new ProcessThread(this, slcExecution).start(); - } - public void execute(RealizedFlow realizedFlow) { if (log.isTraceEnabled()) log.trace("Executing " + realizedFlow); @@ -84,7 +79,7 @@ public abstract class AbstractExecutionModulesManager implements // } - public void dispatchUpdateStatus(SlcExecution slcExecution, + public void dispatchUpdateStatus(ExecutionProcess slcExecution, String oldStatus, String newStatus) { for (Iterator it = getSlcExecutionNotifiers() .iterator(); it.hasNext();) { @@ -92,7 +87,8 @@ public abstract class AbstractExecutionModulesManager implements } } - public void dispatchAddStep(SlcExecution slcExecution, SlcExecutionStep step) { + public void dispatchAddStep(ExecutionProcess slcExecution, + SlcExecutionStep step) { List steps = new ArrayList(); steps.add(step); for (Iterator it = getSlcExecutionNotifiers() @@ -114,13 +110,4 @@ public abstract class AbstractExecutionModulesManager implements return processesThreadGroup; } - protected List getExecutionModulesListeners() { - return executionModulesListeners; - } - - public void setExecutionModulesListeners( - List executionModulesListeners) { - this.executionModulesListeners = executionModulesListeners; - } - }