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=099498caa28409cf2225578057c8dfe5d6d65d17;hb=61dd39a53c7635693b520e7e26583a5bde50430e;hp=66c0718fc946c29f6a8199990123496357f3633d;hpb=ab459c7e28f29c0695d159f7971337e3b5884c6e;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 66c0718fc..099498caa 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 @@ -12,6 +12,7 @@ import javax.jms.MessageListener; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.argeo.slc.SlcException; +import org.argeo.slc.core.runtime.AbstractAgent; import org.argeo.slc.process.SlcExecution; import org.argeo.slc.runtime.SlcAgent; import org.argeo.slc.runtime.SlcAgentDescriptor; @@ -20,7 +21,7 @@ import org.springframework.beans.factory.InitializingBean; import org.springframework.jms.core.JmsTemplate; /** JMS based implementation of SLC Agent. */ -public class JmsAgent implements SlcAgent, InitializingBean, DisposableBean { +public class JmsAgent extends AbstractAgent implements SlcAgent, InitializingBean, DisposableBean { private final static Log log = LogFactory.getLog(JmsAgent.class); private final SlcAgentDescriptor agentDescriptor; @@ -60,7 +61,8 @@ public class JmsAgent implements SlcAgent, InitializingBean, DisposableBean { } public void newExecution(SlcExecution slcExecution) { - log.info("Would execute SlcExecution :" + slcExecution); + log.info("Execute SlcExecution :" + slcExecution); + runSlcExecution(slcExecution); } public void setJmsTemplate(JmsTemplate jmsTemplate) {