X-Git-Url: http://git.argeo.org/?a=blobdiff_plain;f=runtime%2Forg.argeo.slc.core%2Fsrc%2Fmain%2Fjava%2Forg%2Fargeo%2Fslc%2Fcore%2Fexecution%2FProcessThreadGroup.java;h=969c9b93fba5737c75ea723c601402f991b7d7d9;hb=9ec3a30ade2e331102f3e38667129dc68bece661;hp=5f42f8657ac2aa0ac2fb94394f12d28e5df67cc2;hpb=58e0e18d64a2080680a9f8397b0dfa2894519910;p=gpl%2Fargeo-slc.git diff --git a/runtime/org.argeo.slc.core/src/main/java/org/argeo/slc/core/execution/ProcessThreadGroup.java b/runtime/org.argeo.slc.core/src/main/java/org/argeo/slc/core/execution/ProcessThreadGroup.java index 5f42f8657..969c9b93f 100644 --- a/runtime/org.argeo.slc.core/src/main/java/org/argeo/slc/core/execution/ProcessThreadGroup.java +++ b/runtime/org.argeo.slc.core/src/main/java/org/argeo/slc/core/execution/ProcessThreadGroup.java @@ -23,13 +23,10 @@ import java.util.concurrent.BlockingQueue; import org.argeo.slc.execution.ExecutionModulesManager; import org.argeo.slc.execution.ExecutionProcess; import org.argeo.slc.execution.ExecutionStep; -import org.argeo.slc.process.SlcExecution; -import org.argeo.slc.process.SlcExecutionStep; import org.springframework.security.Authentication; import org.springframework.security.context.SecurityContextHolder; /** The thread group attached to a given {@link SlcExecution}. */ -@SuppressWarnings("deprecation") public class ProcessThreadGroup extends ThreadGroup { private final ExecutionModulesManager executionModulesManager; private final ProcessThread processThread; @@ -54,14 +51,12 @@ public class ProcessThreadGroup extends ThreadGroup { } public void dispatchAddStep(ExecutionStep step) { - // legacy ExecutionProcess slcProcess = processThread.getProcess(); - if (slcProcess instanceof SlcExecution) - ((SlcExecution) slcProcess).getSteps().add((SlcExecutionStep) step); - List steps = new ArrayList(); steps.add(step); + // TODO clarify why we don't dispatch steps, must be a reason // dispatchAddSteps(steps); + slcProcess.addSteps(steps); this.steps.add(step); }