X-Git-Url: http://git.argeo.org/?a=blobdiff_plain;f=runtime%2Forg.argeo.slc.support.activemq%2Fsrc%2Fmain%2Fjava%2Forg%2Fargeo%2Fslc%2Fjms%2FJmsAgent.java;h=9bc3f9e233eacdea683c5c96795f2627abf8eab6;hb=cffd700ca670610a1f81e021f82542dc6bf5c810;hp=33584bb00ca30d9f56544020dbd4bf448d7ef6a8;hpb=548235484edd6b48de5ddc3bbca318e0e49cb57b;p=gpl%2Fargeo-slc.git

diff --git a/runtime/org.argeo.slc.support.activemq/src/main/java/org/argeo/slc/jms/JmsAgent.java b/runtime/org.argeo.slc.support.activemq/src/main/java/org/argeo/slc/jms/JmsAgent.java
index 33584bb00..9bc3f9e23 100644
--- a/runtime/org.argeo.slc.support.activemq/src/main/java/org/argeo/slc/jms/JmsAgent.java
+++ b/runtime/org.argeo.slc.support.activemq/src/main/java/org/argeo/slc/jms/JmsAgent.java
@@ -67,7 +67,8 @@ public class JmsAgent extends DefaultAgent implements MessageListener {
 		}
 	}
 
-	public void dispose() {
+	@Override
+	public void destroy() {
 		try {
 			jmsTemplate.convertAndSend(agentUnregister, getAgentDescriptor());
 			log.info("Agent #" + getAgentUuid() + " unregistered from "
@@ -78,7 +79,7 @@ public class JmsAgent extends DefaultAgent implements MessageListener {
 			if (log.isTraceEnabled())
 				log.debug("Original error.", e);
 		}
-		super.dispose();
+		super.destroy();
 	}
 
 	public void setAgentRegister(Destination agentRegister) {
@@ -162,7 +163,7 @@ public class JmsAgent extends DefaultAgent implements MessageListener {
 				final SlcExecution slcExecution = (SlcExecution) convertFrom(message);
 				new Thread() {
 					public void run() {
-						runSlcExecution(slcExecution);
+						process(slcExecution);
 					}
 				}.start();
 				return ExecutionAnswer.ok("Execution started on agent "