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=47e218301ff08b1c7eae374398a277c140c0eb10;hb=9c82ed02a7ee7b4a757853d8160587b27e493f1a;hp=d264042f96f573457c72ca2d145d2d906b9cb6d4;hpb=e5249c75ef672c95d9cf5405b05cabf6083d18a6;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 d264042f9..47e218301 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 @@ -2,7 +2,6 @@ package org.argeo.slc.jms; import java.net.InetAddress; import java.net.UnknownHostException; -import java.util.ArrayList; import java.util.List; import java.util.UUID; @@ -15,7 +14,6 @@ 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.execution.ExecutionModule; import org.argeo.slc.execution.ExecutionModuleDescriptor; import org.argeo.slc.msg.ExecutionAnswer; import org.argeo.slc.msg.MsgConstants; @@ -107,17 +105,7 @@ public class JmsAgent extends AbstractAgent implements SlcAgent, } public List listExecutionModuleDescriptors() { - List modules = getModulesManager() - .listExecutionModules(); - - List descriptors = new ArrayList(); - for (ExecutionModule module : modules) { - ExecutionModuleDescriptor md = new ExecutionModuleDescriptor(); - md.setName(module.getName()); - md.setVersion(module.getVersion()); - descriptors.add(md); - } - return descriptors; + return getModulesManager().listExecutionModules(); } public boolean ping() { @@ -158,7 +146,8 @@ public class JmsAgent extends AbstractAgent implements SlcAgent, public Message postProcessMessage(Message messageToSend) throws JMSException { messageToSend.setStringProperty(PROPERTY_QUERY, query); - messageToSend.setStringProperty(MsgConstants.PROPERTY_SLC_AGENT_ID, + messageToSend.setStringProperty( + MsgConstants.PROPERTY_SLC_AGENT_ID, agentDescriptor.getUuid()); messageToSend.setJMSCorrelationID(correlationId); return messageToSend;