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=d7fa4f959eb45361d444b21e1ee08442a3322a1a;hb=bf943f312a0a44eccbbfc592be26291f63e63608;hp=893d878fd99ae6ff8d9a427bc140ecc58abdaeef;hpb=f5619266b1acabf1cc375487818c3d6a6e0614dc;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 893d878fd..d7fa4f959 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 @@ -26,13 +26,15 @@ 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; - + private final Authentication authentication; private final static Integer STEPS_BUFFER_CAPACITY = 5000; private BlockingQueue steps = new ArrayBlockingQueue( @@ -44,6 +46,12 @@ public class ProcessThreadGroup extends ThreadGroup { + " thread group"); this.executionModulesManager = executionModulesManager; this.processThread = processThread; + this.authentication = SecurityContextHolder.getContext() + .getAuthentication(); + } + + public Authentication getAuthentication() { + return authentication; } public void dispatchAddStep(ExecutionStep step) {