import java.io.IOException;
import javax.jms.ConnectionFactory;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Session;
import org.apache.activemq.spring.ActiveMQConnectionFactory;
import org.apache.commons.io.IOUtils;
import org.springframework.core.io.ClassPathResource;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;
public class JmsMessageSender {
JmsTemplate jmsTemplate;
public JmsMessageSender() {
jmsTemplate = jmsTemplate();
}
public ConnectionFactory connectionFactory() {
ActiveMQConnectionFactory activeMQConnectionFactory = new ActiveMQConnectionFactory();
activeMQConnectionFactory.setBrokerURL("tcp://localhost:61616");
return activeMQConnectionFactory;
}
public JmsTemplate jmsTemplate() {
JmsTemplate jmsTemplate = new JmsTemplate();
jmsTemplate.setConnectionFactory(connectionFactory());
return jmsTemplate;
}
public void sendJmsMessage(String destinationName, final String message) throws IOException {
jmsTemplate.send(destinationName, new MessageCreator() {
@Override
public Message createMessage(Session session) throws JMSException {
return session.createTextMessage(message);
}
});
}
public static void main(String[] args) throws Exception {
final ClassPathResource classPathResource = new ClassPathResource("message1.xml");
final String message = IOUtils.toString(classPathResource.getInputStream());
new JmsMessageSender().sendJmsMessage("RequestQueue", message);
}
}
Thursday, June 2, 2011
Spring jms - Sending message using Activemq
Subscribe to:
Posts (Atom)