X-Git-Url: http://git.argeo.org/?a=blobdiff_plain;f=runtime%2Forg.argeo.slc.lib.detached%2Fsrc%2Fmain%2Fjava%2Forg%2Fargeo%2Fslc%2Fant%2Fdetached%2FSlcDetachedTask.java;fp=runtime%2Forg.argeo.slc.lib.detached%2Fsrc%2Fmain%2Fjava%2Forg%2Fargeo%2Fslc%2Fant%2Fdetached%2FSlcDetachedTask.java;h=d973d381513b141546f50730d76fad664cb88138;hb=8235a54f85d7ff7ba23873c7612d50097ecdd809;hp=0000000000000000000000000000000000000000;hpb=8279efc2b92ba454b24ad4d06e7878b00836c07d;p=gpl%2Fargeo-slc.git

diff --git a/runtime/org.argeo.slc.lib.detached/src/main/java/org/argeo/slc/ant/detached/SlcDetachedTask.java b/runtime/org.argeo.slc.lib.detached/src/main/java/org/argeo/slc/ant/detached/SlcDetachedTask.java
new file mode 100644
index 000000000..d973d3815
--- /dev/null
+++ b/runtime/org.argeo.slc.lib.detached/src/main/java/org/argeo/slc/ant/detached/SlcDetachedTask.java
@@ -0,0 +1,76 @@
+package org.argeo.slc.ant.detached;
+
+import java.util.Properties;
+import java.util.UUID;
+
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.argeo.slc.ant.spring.MapArg;
+import org.argeo.slc.ant.structure.SAwareTask;
+import org.argeo.slc.core.SlcException;
+import org.argeo.slc.detached.DetachedAnswer;
+import org.argeo.slc.detached.DetachedClient;
+import org.argeo.slc.detached.DetachedRequest;
+import org.argeo.slc.spring.SpringUtils;
+
+public class SlcDetachedTask extends SAwareTask {
+	private final static Log log = LogFactory.getLog(SlcDetachedTask.class);
+
+	private String client;
+	private String action;
+
+	private MapArg properties;
+
+	@Override
+	protected void executeActions(String mode) {
+		// Find detached client
+		DetachedClient detachedClient = null;
+		if (client != null)
+			detachedClient = getBean(client);
+		else
+			detachedClient = SpringUtils.loadSingleFromContext(getContext(),
+					DetachedClient.class);
+
+		if (detachedClient == null)
+			throw new SlcException("Could not find any detached client.");
+
+		// Prepare and send request
+		DetachedRequest request = new DetachedRequest(UUID.randomUUID()
+				.toString());
+		request.setRef(action);
+
+		if (properties != null) {
+			Properties props = new Properties();
+			props.putAll(properties.getMap());
+			request.setProperties(props);
+		}
+
+		try {
+			detachedClient.sendRequest(request);
+			DetachedAnswer answer = detachedClient.receiveAnswer();
+			if (answer.getStatus() == DetachedAnswer.ERROR)
+				throw new SlcException("Error when executing request "
+						+ answer.getUuid() + ": " + answer.getLog());
+			else
+				log.info("Admin answer: " + answer.getLog());
+		} catch (Exception e) {
+			throw new SlcException("Could not send request.", e);
+		}
+	}
+
+	public void setClient(String driverBean) {
+		this.client = driverBean;
+	}
+
+	public void setAction(String action) {
+		this.action = action;
+	}
+
+	public MapArg createProperties() {
+		if (properties == null)
+			properties = new MapArg();
+		else
+			throw new SlcException("Properties already declared.");
+		return properties;
+	}
+}