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;
/** 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);
}
Session session = null;
if (getProcess() instanceof JcrExecutionProcess)
try {
- session = ((JcrExecutionProcess) getProcess()).getRepository()
- .login();
+ session = ((JcrExecutionProcess) getProcess()).getRepository().login(NodeConstants.HOME);
- 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 {
//
execute(realizedFlow, true);
- setFlowStatus(realizedFlowNode,
- ExecutionProcess.COMPLETED);
+ setFlowStatus(realizedFlowNode, ExecutionProcess.COMPLETED);
} catch (RepositoryException e) {
throw e;
} catch (InterruptedException e) {
}
}
} catch (RepositoryException e) {
- throw new SlcException("Cannot process "
- + getJcrExecutionProcess().getNodePath(), e);
+ throw new SlcException("Cannot process " + getJcrExecutionProcess().getNodePath(), e);
} finally {
JcrUtils.logoutQuietly(session);
}
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();
}