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=98bbf5272e992f5546df3f84175749f3ec671c7d;hb=a0a151ee3a0aed29a3cb03d81e35d540ca9fdb03;hp=893d878fd99ae6ff8d9a427bc140ecc58abdaeef;hpb=60677ee743e6d54ceda3187824cef28cf844ccc0;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..98bbf5272 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 @@ -1,5 +1,5 @@ /* - * Copyright (C) 2010 Mathieu Baudier + * Copyright (C) 2007-2012 Mathieu Baudier * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -13,7 +13,6 @@ * See the License for the specific language governing permissions and * limitations under the License. */ - package org.argeo.slc.core.execution; import java.util.ArrayList; @@ -26,13 +25,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 +45,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) {