X-Git-Url: http://git.argeo.org/?a=blobdiff_plain;ds=sidebyside;f=org.argeo.slc.core%2Fsrc%2Forg%2Fargeo%2Fslc%2Fjcr%2Fexecution%2FJcrProcessThread.java;fp=org.argeo.slc.core%2Fsrc%2Forg%2Fargeo%2Fslc%2Fjcr%2Fexecution%2FJcrProcessThread.java;h=0000000000000000000000000000000000000000;hb=e14154d2baba78852915304d51cbb56bed1d3d3e;hp=a73e1a94ae97cb7494b6ad88c7d012892853803c;hpb=aba0f1135009d9014c42368ecea338088e6d2be1;p=gpl%2Fargeo-slc.git

diff --git a/org.argeo.slc.core/src/org/argeo/slc/jcr/execution/JcrProcessThread.java b/org.argeo.slc.core/src/org/argeo/slc/jcr/execution/JcrProcessThread.java
deleted file mode 100644
index a73e1a94a..000000000
--- a/org.argeo.slc.core/src/org/argeo/slc/jcr/execution/JcrProcessThread.java
+++ /dev/null
@@ -1,95 +0,0 @@
-/*
-
- * Copyright (C) 2007-2012 Argeo GmbH
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *         http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.argeo.slc.jcr.execution;
-
-import java.util.List;
-
-import javax.jcr.Node;
-import javax.jcr.RepositoryException;
-import javax.jcr.Session;
-
-import org.argeo.jcr.JcrUtils;
-import org.argeo.slc.SlcException;
-import org.argeo.slc.SlcNames;
-import org.argeo.slc.core.execution.ProcessThread;
-import org.argeo.slc.execution.ExecutionModulesManager;
-import org.argeo.slc.execution.ExecutionProcess;
-import org.argeo.slc.execution.RealizedFlow;
-
-/** Where the actual execution takes place */
-public class JcrProcessThread extends ProcessThread implements SlcNames {
-
-	public JcrProcessThread(ThreadGroup processesThreadGroup,
-			ExecutionModulesManager executionModulesManager,
-			JcrExecutionProcess process) {
-		super(processesThreadGroup, executionModulesManager, process);
-	}
-
-	/** Overridden in order to set progress status on realized flow nodes. */
-	@Override
-	protected void process() throws InterruptedException {
-		Session session = null;
-		if (getProcess() instanceof JcrExecutionProcess)
-			try {
-				session = ((JcrExecutionProcess) getProcess()).getRepository()
-						.login();
-
-				List<RealizedFlow> realizedFlows = getProcess()
-						.getRealizedFlows();
-				for (RealizedFlow realizedFlow : realizedFlows) {
-					Node realizedFlowNode = session
-							.getNode(((JcrRealizedFlow) realizedFlow).getPath());
-					setFlowStatus(realizedFlowNode, ExecutionProcess.RUNNING);
-
-					try {
-						//
-						// EXECUTE THE FLOW
-						//
-						execute(realizedFlow, true);
-
-						setFlowStatus(realizedFlowNode,
-								ExecutionProcess.COMPLETED);
-					} catch (RepositoryException e) {
-						throw e;
-					} catch (InterruptedException e) {
-						setFlowStatus(realizedFlowNode, ExecutionProcess.KILLED);
-						throw e;
-					} catch (RuntimeException e) {
-						setFlowStatus(realizedFlowNode, ExecutionProcess.ERROR);
-						throw e;
-					}
-				}
-			} catch (RepositoryException e) {
-				throw new SlcException("Cannot process "
-						+ getJcrExecutionProcess().getNodePath(), e);
-			} finally {
-				JcrUtils.logoutQuietly(session);
-			}
-		else
-			super.process();
-	}
-
-	protected void setFlowStatus(Node realizedFlowNode, String status)
-			throws RepositoryException {
-		realizedFlowNode.setProperty(SLC_STATUS, status);
-		realizedFlowNode.getSession().save();
-	}
-
-	protected JcrExecutionProcess getJcrExecutionProcess() {
-		return (JcrExecutionProcess) getProcess();
-	}
-}