import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
-import org.argeo.slc.SlcException;
import org.argeo.slc.execution.ExecutionFlowDescriptor;
import org.argeo.slc.execution.ExecutionStep;
import org.argeo.slc.process.RealizedFlow;
-import org.springframework.security.Authentication;
-import org.springframework.security.context.SecurityContextHolder;
/** Thread of a single execution */
public class ExecutionThread extends Thread {
public void run() {
// authenticate thread
- Authentication authentication = getProcessThreadGroup()
- .getAuthentication();
- if (authentication == null)
- throw new SlcException("Can only execute authenticated threads");
- SecurityContextHolder.getContext().setAuthentication(authentication);
+// Authentication authentication = getProcessThreadGroup()
+// .getAuthentication();
+// if (authentication == null)
+// throw new SlcException("Can only execute authenticated threads");
+// SecurityContextHolder.getContext().setAuthentication(authentication);
if (getContextClassLoader() != null) {
if (log.isTraceEnabled())
import org.argeo.slc.execution.ExecutionStep;
import org.argeo.slc.process.RealizedFlow;
import org.argeo.slc.process.SlcExecution;
-import org.springframework.security.Authentication;
-import org.springframework.security.context.SecurityContextHolder;
/** Thread of the SLC Process, starting the sub executions. */
@SuppressWarnings("deprecation")
public final void run() {
// authenticate thread
- Authentication authentication = getProcessThreadGroup()
- .getAuthentication();
- if (authentication == null)
- throw new SlcException("Can only execute authenticated threads");
- SecurityContextHolder.getContext().setAuthentication(authentication);
-
- log.info("\n##\n## SLC Process #" + process.getUuid() + " STARTED by "
- + authentication.getName() + "\n##\n");
+ // Authentication authentication = getProcessThreadGroup()
+ // .getAuthentication();
+ // if (authentication == null)
+ // throw new SlcException("Can only execute authenticated threads");
+ // SecurityContextHolder.getContext().setAuthentication(authentication);
+
+ // log.info("\n##\n## SLC Process #" + process.getUuid() +
+ // " STARTED by "
+ // + authentication.getName() + "\n##\n");
+ log.info("\n##\n## SLC Process #" + process.getUuid()
+ + " STARTED\n##\n");
// Start logging
new LoggingThread().start();
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 Authentication authentication;
private final static Integer STEPS_BUFFER_CAPACITY = 5000;
private BlockingQueue<ExecutionStep> steps = new ArrayBlockingQueue<ExecutionStep>(
+ " thread group");
this.executionModulesManager = executionModulesManager;
this.processThread = processThread;
- this.authentication = SecurityContextHolder.getContext()
- .getAuthentication();
+// this.authentication = SecurityContextHolder.getContext()
+// .getAuthentication();
}
- public Authentication getAuthentication() {
- return authentication;
- }
+// public Authentication getAuthentication() {
+// return authentication;
+// }
public void dispatchAddStep(ExecutionStep step) {
// legacy
private BundleContext bundleContext;
- private Long defaultTimeout = 120 * 1000l;
+ private Long defaultTimeout = 30 * 1000l;
private Long pollingPeriod = 200l;
// Refresh sync objects