X-Git-Url: http://git.argeo.org/?a=blobdiff_plain;f=runtime%2Forg.argeo.slc.support.activemq%2Fsrc%2Fmain%2Fjava%2Forg%2Fargeo%2Fslc%2Fjms%2FJmsAgentProxyFactory.java;fp=runtime%2Forg.argeo.slc.support.activemq%2Fsrc%2Fmain%2Fjava%2Forg%2Fargeo%2Fslc%2Fjms%2FJmsAgentProxyFactory.java;h=1f625e13fb3e0a292a8af21204ddccd8f297b8c8;hb=cebfbf8efbf6a6b99a543bd309d2976478123989;hp=0000000000000000000000000000000000000000;hpb=cf11e8611ca597abd82f93b4642807f9c19aed1f;p=gpl%2Fargeo-slc.git diff --git a/runtime/org.argeo.slc.support.activemq/src/main/java/org/argeo/slc/jms/JmsAgentProxyFactory.java b/runtime/org.argeo.slc.support.activemq/src/main/java/org/argeo/slc/jms/JmsAgentProxyFactory.java new file mode 100644 index 000000000..1f625e13f --- /dev/null +++ b/runtime/org.argeo.slc.support.activemq/src/main/java/org/argeo/slc/jms/JmsAgentProxyFactory.java @@ -0,0 +1,37 @@ +package org.argeo.slc.jms; + +import javax.jms.Destination; + +import org.argeo.slc.runtime.SlcAgent; +import org.argeo.slc.runtime.SlcAgentFactory; +import org.springframework.jms.core.JmsTemplate; +import org.springframework.jms.support.converter.MessageConverter; + +public class JmsAgentProxyFactory implements SlcAgentFactory { + private Destination requestDestination; + private Destination responseDestination; + private JmsTemplate jmsTemplate; + private MessageConverter messageConverter; + + public SlcAgent getAgent(String uuid) { + return new JmsAgentProxy(uuid, requestDestination, responseDestination, + jmsTemplate, messageConverter); + } + + public void setRequestDestination(Destination requestDestination) { + this.requestDestination = requestDestination; + } + + public void setResponseDestination(Destination responseDestination) { + this.responseDestination = responseDestination; + } + + public void setJmsTemplate(JmsTemplate jmsTemplate) { + this.jmsTemplate = jmsTemplate; + } + + public void setMessageConverter(MessageConverter messageConverter) { + this.messageConverter = messageConverter; + } + +}