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=304125ea23a3570c78149816d76951bbb258707d;hp=74f1eb2318c26cc64c3ac4835fed94d6a697aa5f;hpb=61cf879a296d5afdb5d0b6aaa7c6bea1eed9e442;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 74f1eb231..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,7 @@ 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; @@ -19,7 +20,7 @@ public class JmsTransferNewExecution implements MessageListener { 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);