Fix SLC

[gpl/argeo-slc.git] / runtime / org.argeo.slc.support.activemq / src / main / java / org / argeo / slc / jms / JmsAgent.java

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 33584bb00ca30d9f56544020dbd4bf448d7ef6a8..9bc3f9e233eacdea683c5c96795f2627abf8eab6 100644 (file)
--- 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 "