X-Git-Url: http://git.argeo.org/?a=blobdiff_plain;f=org.argeo.slc.jcr%2Fsrc%2Forg%2Fargeo%2Fslc%2Fjcr%2Fexecution%2FJcrProcessThread.java;h=34860d0dd960873aab64b142ddaedcef524011fa;hb=58b35f147f3c1c1a12a07c303105618f679c7161;hp=56b97d02e7aa550a98e63126efb6a959195f9bd5;hpb=810d3b29b3678cbe4b9a6af8e281757c6e820ee4;p=gpl%2Fargeo-slc.git

diff --git a/org.argeo.slc.jcr/src/org/argeo/slc/jcr/execution/JcrProcessThread.java b/org.argeo.slc.jcr/src/org/argeo/slc/jcr/execution/JcrProcessThread.java
index 56b97d02e..34860d0dd 100644
--- a/org.argeo.slc.jcr/src/org/argeo/slc/jcr/execution/JcrProcessThread.java
+++ b/org.argeo.slc.jcr/src/org/argeo/slc/jcr/execution/JcrProcessThread.java
@@ -22,6 +22,7 @@ import javax.jcr.Node;
 import javax.jcr.RepositoryException;
 import javax.jcr.Session;
 
+import org.argeo.api.NodeConstants;
 import org.argeo.jcr.JcrUtils;
 import org.argeo.slc.SlcException;
 import org.argeo.slc.SlcNames;
@@ -33,8 +34,7 @@ import org.argeo.slc.runtime.ProcessThread;
 /** Where the actual execution takes place */
 public class JcrProcessThread extends ProcessThread implements SlcNames {
 
-	public JcrProcessThread(ThreadGroup processesThreadGroup,
-			ExecutionModulesManager executionModulesManager,
+	public JcrProcessThread(ThreadGroup processesThreadGroup, ExecutionModulesManager executionModulesManager,
 			JcrExecutionProcess process) {
 		super(processesThreadGroup, executionModulesManager, process);
 	}
@@ -45,14 +45,11 @@ public class JcrProcessThread extends ProcessThread implements SlcNames {
 		Session session = null;
 		if (getProcess() instanceof JcrExecutionProcess)
 			try {
-				session = ((JcrExecutionProcess) getProcess()).getRepository()
-						.login();
+				session = ((JcrExecutionProcess) getProcess()).getRepository().login(NodeConstants.HOME_WORKSPACE);
 
-				List<RealizedFlow> realizedFlows = getProcess()
-						.getRealizedFlows();
+				List<RealizedFlow> realizedFlows = getProcess().getRealizedFlows();
 				for (RealizedFlow realizedFlow : realizedFlows) {
-					Node realizedFlowNode = session
-							.getNode(((JcrRealizedFlow) realizedFlow).getPath());
+					Node realizedFlowNode = session.getNode(((JcrRealizedFlow) realizedFlow).getPath());
 					setFlowStatus(realizedFlowNode, ExecutionProcess.RUNNING);
 
 					try {
@@ -61,8 +58,7 @@ public class JcrProcessThread extends ProcessThread implements SlcNames {
 						//
 						execute(realizedFlow, true);
 
-						setFlowStatus(realizedFlowNode,
-								ExecutionProcess.COMPLETED);
+						setFlowStatus(realizedFlowNode, ExecutionProcess.COMPLETED);
 					} catch (RepositoryException e) {
 						throw e;
 					} catch (InterruptedException e) {
@@ -74,8 +70,7 @@ public class JcrProcessThread extends ProcessThread implements SlcNames {
 					}
 				}
 			} catch (RepositoryException e) {
-				throw new SlcException("Cannot process "
-						+ getJcrExecutionProcess().getNodePath(), e);
+				throw new SlcException("Cannot process " + getJcrExecutionProcess().getNodePath(), e);
 			} finally {
 				JcrUtils.logoutQuietly(session);
 			}
@@ -83,8 +78,7 @@ public class JcrProcessThread extends ProcessThread implements SlcNames {
 			super.process();
 	}
 
-	protected void setFlowStatus(Node realizedFlowNode, String status)
-			throws RepositoryException {
+	protected void setFlowStatus(Node realizedFlowNode, String status) throws RepositoryException {
 		realizedFlowNode.setProperty(SLC_STATUS, status);
 		realizedFlowNode.getSession().save();
 	}