X-Git-Url: http://git.argeo.org/?a=blobdiff_plain;f=runtime%2Forg.argeo.slc.support.activemq%2Fsrc%2Fmain%2Fjava%2Forg%2Fargeo%2Fslc%2Fjms%2FJmsTransferNewExecution.java;h=aa66dc8da097626178856c0d36207e978e2b8430;hb=7a3833134109e2a119755a34ff357dea39ce40d6;hp=28913aea87e46807b39f60c5f3a07ee64bfcccbc;hpb=a9bd656db864f3f648d375deef6833c2f53f29ba;p=gpl%2Fargeo-slc.git

diff --git a/runtime/org.argeo.slc.support.activemq/src/main/java/org/argeo/slc/jms/JmsTransferNewExecution.java b/runtime/org.argeo.slc.support.activemq/src/main/java/org/argeo/slc/jms/JmsTransferNewExecution.java
index 28913aea8..aa66dc8da 100644
--- a/runtime/org.argeo.slc.support.activemq/src/main/java/org/argeo/slc/jms/JmsTransferNewExecution.java
+++ b/runtime/org.argeo.slc.support.activemq/src/main/java/org/argeo/slc/jms/JmsTransferNewExecution.java
@@ -4,6 +4,8 @@ import javax.jms.Message;
 import javax.jms.MessageListener;
 
 import org.argeo.slc.SlcException;
+import org.argeo.slc.msg.MsgConstants;
+import org.argeo.slc.msg.MsgHandler;
 import org.argeo.slc.process.SlcExecution;
 import org.argeo.slc.runtime.SlcAgent;
 import org.argeo.slc.runtime.SlcAgentFactory;
@@ -13,11 +15,12 @@ import org.springframework.jms.support.converter.MessageConverter;
 public class JmsTransferNewExecution implements MessageListener {
 	private MessageConverter messageConverter;
 	private SlcAgentFactory agentFactory;
+	private MsgHandler serviceMsgHandler;
 
 	public void onMessage(final Message message) {
 		try {
 			String agentId = message
-					.getStringProperty(JmsAgent.PROPERTY_SLC_AGENT_ID);
+					.getStringProperty(MsgConstants.PROPERTY_SLC_AGENT_ID);
 			final SlcAgent agent = agentFactory.getAgent(agentId);
 			final SlcExecution slcExecution = (SlcExecution) messageConverter
 					.fromMessage(message);
@@ -26,6 +29,7 @@ public class JmsTransferNewExecution implements MessageListener {
 					agent.runSlcExecution(slcExecution);
 				}
 			}.start();
+			serviceMsgHandler.handleMsg(slcExecution);
 		} catch (Exception e) {
 			throw new SlcException("Could not transfer new execution "
 					+ message, e);
@@ -40,4 +44,8 @@ public class JmsTransferNewExecution implements MessageListener {
 		this.agentFactory = agentFactory;
 	}
 
+	public void setServiceMsgHandler(MsgHandler serviceMsgHandler) {
+		this.serviceMsgHandler = serviceMsgHandler;
+	}
+
 }