SpringJMS - Step by Step Guide to create Consumer (Super Simple)

Step 1 - You will need same Jar files which we discussed in Producer Example

Spring Core
Spring Context
Spring JMS
activemq-all
commons-logging
slf4j

Step 2: Create applicationContext.xml in classpath

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans"

       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

       xmlns:p="http://www.springframework.org/schema/p"

       xmlns:context="http://www.springframework.org/schema/context"

       xmlns:jms="http://www.springframework.org/schema/jms"

       xmlns:amq="http://activemq.apache.org/schema/core"

       xsi:schemaLocation="http://www.springframework.org/schema/beans 

                           http://www.springframework.org/schema/beans/spring-beans.xsd

                           http://www.springframework.org/schema/context 

                           http://www.springframework.org/schema/context/spring-context.xsd

                           http://www.springframework.org/schema/jms 

                           http://www.springframework.org/schema/jms/spring-jms.xsd

                           http://activemq.apache.org/schema/core 

                           http://activemq.apache.org/schema/core/activemq-core.xsd">

<context:component-scan base-package="com.itech" />

<context:annotation-config/>

<!-- JMS ConnectionFactory to use, configuring the embedded broker using XML -->

<bean id="activemqConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">

    <!-- brokerURL, You may have different IP or port -->

    <constructor-arg name="brokerURL" value="vm://localhost:61616" />

  </bean>  

<!-- Pooled Spring connection factory -->

 <bean id="connectionFactory" class="org.springframework.jms.connection.CachingConnectionFactory">

    <constructor-arg ref="activemqConnectionFactory" />

 </bean>

<!--  Queue Destination  -->

    <bean id="queueDestination" class="org.apache.activemq.command.ActiveMQQueue">

    <!-- name of the queue -->

    <constructor-arg index="0" value="THIS.IS.TEST.QUEUE" />

  </bean>

 

  <!-- Listeners   -->

<jms:listener-container connection-factory="connectionFactory"> 

               <jms:listener destination="THIS.IS.TEST.QUEUE" ref="messageListenerTest" /> 

 </jms:listener-container>

</beans>

Step 3:

You need a Consumer Class which implements MessageListener interface:

import javax.jms.JMSException;

import javax.jms.Message;

import javax.jms.MessageListener;

import javax.jms.TextMessage;

import org.springframework.stereotype.Component;

@Component("messageListenerTest")

public class MessageListenerTest implements MessageListener {

@Override

public void onMessage(Message message) {

TextMessage textMessage = (TextMessage) message;

try {

System.out.println(textMessage.getText());

} catch (JMSException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

}

}

That's it, Now try sending a message with Producer example, and message will be listened by this MessageListener implementation.