import java.net.UnknownHostException;
import java.util.UUID;
+import javax.jms.ConnectionFactory;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.Message;
private final static Log log = LogFactory.getLog(JmsAgent.class);
private final SlcAgentDescriptor agentDescriptor;
+ private ConnectionFactory connectionFactory;
private JmsTemplate jmsTemplate;
private Destination agentRegister;
private Destination agentUnregister;
}
public void afterPropertiesSet() throws Exception {
+ // Initialize JMS Template
+ jmsTemplate = new JmsTemplate(connectionFactory);
+ jmsTemplate.setMessageConverter(messageConverter);
+
jmsTemplate.convertAndSend(agentRegister, agentDescriptor);
log.info("Agent #" + agentDescriptor.getUuid() + " registered to "
+ agentRegister);
+ agentUnregister);
}
- public void setJmsTemplate(JmsTemplate jmsTemplate) {
- this.jmsTemplate = jmsTemplate;
- }
-
public void setAgentRegister(Destination agentRegister) {
this.agentRegister = agentRegister;
}
}
public void onMessage(Message message) {
- // FIXME: we filter the messages on the client side,
+ // FIXME: we filter the messages on the client side,
// because of a weird problem with selector since moving to OSGi
try {
if (message.getStringProperty("slc-agentId").equals(
public void setMessageConverter(MessageConverter messageConverter) {
this.messageConverter = messageConverter;
}
-
-
+
+ public void setConnectionFactory(ConnectionFactory connectionFactory) {
+ this.connectionFactory = connectionFactory;
+ }
+
}