Skip to main content

Posts

Showing posts with the label ActiveMQ

Consuming a JMS Message from ActiveMQ using Spring Message Driven POJO

In my last post, I had shown how you can post a JMS message to a ActiveMQ queue. In this post I will show the reverse process. I will not try to consume this message using a Spring Message Driven POJO. I assume your familiarity with Spring MDP. If not you can look here - http://static.springframework.org/spring/docs/2.5.x/reference/jms.html The operation that I intend to carry out is depicted in Figure 1. Figure 1 - Consuming JMS message using Spring MDP Step 1 - Create the message listener. Listing 1 - EventMessageConsumer.java Step 2 - Wire up the bean in Spring configuration Listing 2 - spring-activemq-config.xml Step 3  - Test Finally you can see the results of message produced and consumed in the Admin web console as shown in Figure 2. Figure 2 - Queue statistics

Sending JMS message to ActiveMQ using Spring 2.5 from a web application

Last Updated 04/16/2017 In this post, I will show how you can send JMS message to ActiveMQ from your Spring web application. I have a Spring 2.5 + JBOSS Richfaces based web application that runs on Tomcat 6 running on JDK 5. Figure 1. depicts what I intend to do. Figure - 1 Send JMS Message to ActiveMQ using Spring from a web application Step 1: Drop in the following jars to WEB-INF/lib activemq-core-5.2.0.jar jms.jar geronimo-j2ee-management_1.0_spec-1.0.jar Step 2: Create the destination/Queue using the ActiveMQ admin web application. Launch your browser and point it to - http://localhost:8161/admin/ Figure 2 - ActiveMQ Admin Console Click on 'Queues' to navigate to queue list and create screen. You will need to supply the queue name and click on 'Create' to create a new queue destination on ActiveMQ server. This is shown in Figure 3. Figure 3 - Create a new Queue Step 3. Create a message producer interface . This may not be necessary...