X-Git-Url: http://git.argeo.org/?a=blobdiff_plain;f=org.argeo.slc.core%2Fsrc%2Fmain%2Fjava%2Forg%2Fargeo%2Fslc%2Fcore%2Fprocess%2FWebServiceSlcExecutionNotifier.java;fp=org.argeo.slc.core%2Fsrc%2Fmain%2Fjava%2Forg%2Fargeo%2Fslc%2Fcore%2Fprocess%2FWebServiceSlcExecutionNotifier.java;h=0000000000000000000000000000000000000000;hb=2d5e7c7e91522b14d917fdd8cb39c0df1b25bf11;hp=9692344877fde1bdbecc46ce750bc858464acf53;hpb=f366b06720d300b3e20f996902d0c2dab55a3473;p=gpl%2Fargeo-slc.git

diff --git a/org.argeo.slc.core/src/main/java/org/argeo/slc/core/process/WebServiceSlcExecutionNotifier.java b/org.argeo.slc.core/src/main/java/org/argeo/slc/core/process/WebServiceSlcExecutionNotifier.java
deleted file mode 100644
index 969234487..000000000
--- a/org.argeo.slc.core/src/main/java/org/argeo/slc/core/process/WebServiceSlcExecutionNotifier.java
+++ /dev/null
@@ -1,117 +0,0 @@
-package org.argeo.slc.core.process;
-
-import java.util.List;
-
-import org.springframework.ws.client.WebServiceIOException;
-import org.springframework.ws.client.core.WebServiceTemplate;
-import org.springframework.ws.soap.client.SoapFaultClientException;
-
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
-
-import org.argeo.slc.msg.process.SlcExecutionRequest;
-import org.argeo.slc.msg.process.SlcExecutionStatusRequest;
-import org.argeo.slc.msg.process.SlcExecutionStepsRequest;
-import org.argeo.slc.ws.client.WebServiceUtils;
-
-public class WebServiceSlcExecutionNotifier implements SlcExecutionNotifier {
-	private WebServiceTemplate template;
-
-	private Log log = LogFactory.getLog(getClass());
-
-	private Boolean cannotConnect = false;
-
-	public void newExecution(SlcExecution slcExecution) {
-		if (cannotConnect)
-			return;
-
-		SlcExecutionRequest req = new SlcExecutionRequest();
-		req.setSlcExecution(slcExecution);
-		try {
-			WebServiceUtils.marshalSendAndReceive(template, req);
-			if (log.isTraceEnabled())
-				log.trace("Notified creation of slc execution "
-						+ slcExecution.getUuid());
-		} catch (SoapFaultClientException e) {
-			WebServiceUtils.manageSoapException(e);
-		} catch (WebServiceIOException e) {
-			manageIoException(e);
-		}
-	}
-
-	public void updateExecution(SlcExecution slcExecution) {
-		if (cannotConnect)
-			return;
-
-		SlcExecutionRequest req = new SlcExecutionRequest();
-		req.setSlcExecution(slcExecution);
-		try {
-			WebServiceUtils.marshalSendAndReceive(template, req);
-			if (log.isTraceEnabled())
-				log.trace("Notified update of slc execution "
-						+ slcExecution.getUuid());
-		} catch (SoapFaultClientException e) {
-			WebServiceUtils.manageSoapException(e);
-		} catch (WebServiceIOException e) {
-			manageIoException(e);
-		}
-	}
-
-	public void updateStatus(SlcExecution slcExecution, String oldStatus,
-			String newStatus) {
-		if (cannotConnect)
-			return;
-
-		SlcExecutionStatusRequest req = new SlcExecutionStatusRequest(
-				slcExecution.getUuid(), newStatus);
-		try {
-			WebServiceUtils.marshalSendAndReceive(template, req);
-			if (log.isTraceEnabled())
-				log.trace("Notified status update of slc execution "
-						+ slcExecution.getUuid());
-		} catch (SoapFaultClientException e) {
-			WebServiceUtils.manageSoapException(e);
-		} catch (WebServiceIOException e) {
-			manageIoException(e);
-		}
-	}
-
-	public void addSteps(SlcExecution slcExecution,
-			List<SlcExecutionStep> additionalSteps) {
-		if (cannotConnect)
-			return;
-
-		SlcExecutionStepsRequest req = new SlcExecutionStepsRequest();
-		req.setSlcExecutionUuid(slcExecution.getUuid());
-		req.setSteps(additionalSteps);
-		if (log.isTraceEnabled()) {
-			for (SlcExecutionStep step : additionalSteps) {
-				log.trace("Step " + step.getUuid() + ": " + step.logAsString());
-			}
-		}
-
-		try {
-			WebServiceUtils.marshalSendAndReceive(template, req);
-			if (log.isTraceEnabled())
-				log.trace("Added steps to slc execution "
-						+ slcExecution.getUuid());
-		} catch (SoapFaultClientException e) {
-			WebServiceUtils.manageSoapException(e);
-		} catch (WebServiceIOException e) {
-			manageIoException(e);
-		}
-	}
-
-	public void setTemplate(WebServiceTemplate template) {
-		this.template = template;
-	}
-
-	protected void manageIoException(WebServiceIOException e) {
-		if (!cannotConnect) {
-			log.error("Cannot connect to " + template.getDefaultUri()
-					+ ". Won't try again.", e);
-			cannotConnect = true;
-		}
-	}
-
-}