X-Git-Url: http://git.argeo.org/?a=blobdiff_plain;ds=inline;f=org.argeo.slc.agent%2Fsrc%2Fmain%2Fjava%2Forg%2Fargeo%2Fslc%2Fant%2Fdetached%2FSlcDetachedTask.java;fp=org.argeo.slc.agent%2Fsrc%2Fmain%2Fjava%2Forg%2Fargeo%2Fslc%2Fant%2Fdetached%2FSlcDetachedTask.java;h=0000000000000000000000000000000000000000;hb=cdb5a9f10678f41914d6eeebd6620c0a84dbd208;hp=d973d381513b141546f50730d76fad664cb88138;hpb=7a8f034133c1112e187e2a2bfd2c56a8d2452345;p=gpl%2Fargeo-slc.git diff --git a/org.argeo.slc.agent/src/main/java/org/argeo/slc/ant/detached/SlcDetachedTask.java b/org.argeo.slc.agent/src/main/java/org/argeo/slc/ant/detached/SlcDetachedTask.java deleted file mode 100644 index d973d3815..000000000 --- a/org.argeo.slc.agent/src/main/java/org/argeo/slc/ant/detached/SlcDetachedTask.java +++ /dev/null @@ -1,76 +0,0 @@ -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; - } -}