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%2FProcessThreadGroup.java;h=61e8c2f2a063c6630cf39aa7f399b65399d0751b;hb=3781dcd363f0f6265fae0ac758fd40cf4254ebc9;hp=1574b97d6761a1a62318d2a050bf11b1a693aacc;hpb=30f4c6af6c20077e5e36b61faf5edb22c1aae6c6;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 1574b97d6..61e8c2f2a 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 @@ -17,6 +17,7 @@ package org.argeo.slc.core.execution; import org.argeo.slc.execution.ExecutionModulesManager; +import org.argeo.slc.execution.ExecutionProcess; import org.argeo.slc.process.SlcExecution; import org.argeo.slc.process.SlcExecutionStep; @@ -27,19 +28,20 @@ public class ProcessThreadGroup extends ThreadGroup { public ProcessThreadGroup(ExecutionModulesManager executionModulesManager, ProcessThread processThread) { - super("SLC Process #" + processThread.getSlcProcess().getUuid() + super("SLC Process #" + processThread.getProcess().getUuid() + " thread group"); this.executionModulesManager = executionModulesManager; this.processThread = processThread; } - public SlcExecution getSlcProcess() { - return processThread.getSlcProcess(); - } + // public SlcExecution getSlcProcess() { + // return processThread.getSlcProcess(); + // } public void dispatchAddStep(SlcExecutionStep step) { - SlcExecution slcProcess = processThread.getSlcProcess(); - slcProcess.getSteps().add(step); + ExecutionProcess slcProcess = processThread.getProcess(); + if (slcProcess instanceof SlcExecution) + ((SlcExecution) slcProcess).getSteps().add(step); executionModulesManager.dispatchAddStep(slcProcess, step); }