ActiveMQ with Spring-JMS

This is a jms example using Spring-JMS and ActiveMQ.

Dependencies

Spring Framework 3.2 {Core, Context, JMS}

ActiveMQ 5.8.0

Getting Started

Setting up ActiveMQ

1. Install ActiveMQ on the local machine(localhost). Check the Getting Started guide.
2. Login to the ActiveMQ admin console and create a queue named testSpringJms.

Spring JMS

Reference manual is Here.

Code walk-through

Message sender class

Class name - MessageSender.java, uses Spring JMS Template

/**
 * Inject a JMS Template
 * @param jmsTemplate
 */
public MessageSender(JmsTemplate jmsTemplate) {
    this.jmsTemplate = jmsTemplate;
}

Message receiver class

Class name - MessageReceiver.java, implements javax.jms.MessageListener

/**
 * Implement javax.jms.MessageListener interface
 *
 * @author Syamantak Mukhopadhyay
 */
public class MessageReceiver implements MessageListener {
    @Override
    public void onMessage(Message message) {
        ....
    }
}

Spring configuration

Context Configuration file - applicationContext.xml

Queue url and name

test/resources/mq-example.properties

jms.broker.url=tcp://localhost:61616
jms.queue.name=testSpringJms