Spring Boot JMS ActiveMQ Messaging Example - Java Guides

Skip to main content

Spring 7 and Spring Boot 4 for Beginners (Includes 8 Projects)

Bestseller 85% OFF

Building Real-Time REST APIs with Spring Boot - Blog App

Bestseller 85% OFF

Building Microservices with Spring Boot and Spring Cloud

Top Rated 85% OFF

Full-Stack Java Development with Spring Boot 4 and React

Bestseller 85% OFF

Build 5 Spring Boot Projects with Java: Line-by-Line Coding

Projects 85% OFF

Testing Spring Boot Application with JUnit and Mockito

Bestseller 85% OFF

ChatGPT for Java Developers: Boost Your Productivity with AI

Trending 85% OFF

Spring Boot Thymeleaf Real-Time Web Application - Blog App

Bestseller 85% OFF

Master Spring Data JPA with Hibernate

Favorite 85% OFF

Spring Boot + Apache Kafka Course - The Practical Guide

Bestseller 85% OFF

Java Testing: Mastering JUnit 5 Framework

New 85% OFF

Reactive Programming in Java: Spring WebFlux and Testing

New 85% OFF

Spring Boot + RabbitMQ Course - The Practical Guide

Bestseller 85% OFF

Free Courses on YouTube Channel

175K Subscribers

Spring Boot JMS ActiveMQ Messaging Example

Author: Ramesh Fadatare Spring Boot

• Get link
• Facebook
• X
• Pinterest
• Email
• Other Apps

🎓 Top 15 Udemy Courses (80-90% Discount): My Udemy Courses - Ramesh Fadatare — All my Udemy courses are real-time and project oriented courses.

▶️ Subscribe to My YouTube Channel (178K+ subscribers): Java Guides on YouTube

▶️ For AI, ChatGPT, Web, Tech, and Generative AI, subscribe to another channel: Ramesh Fadatare on YouTube

In this article, we will create a simple Spring Boot JMS application that uses Spring’s JmsTemplate to post a single message and subscribes to it with a @JmsListener annotated method of a managed bean.

Spring Boot ActiveMQ Support

Spring boot automatically configures the ConnectionFactory class if it detects ActiveMQ on the classpath. In this case, it also makes use of an embedded broker if does not find any ActiveMQ custom configurations in application.properties. In this example, we will be using the default ActiveMQ configuration. Below maven dependency provides all the required dependencies to integrate JMS and ActiveMQ with spring boot. <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-activemq</artifactId> </dependency> The below dependency provides embedded ActiveMQ in the spring boot application: <dependency> <groupId>org.apache.activemq</groupId> <artifactId>activemq-broker</artifactId> </dependency>

Short Note on ActiveMQ

There are quite a few JMS implementations out there. Most of them are provided by Middle Oriented Middleware providers, for example, WebSphere MQ, Oracle EMS, JBoss AP, SwiftMQ, TIBCO EMS, SonicMQ, ActiveMQ, and WebLogic JMS. Some are open-source, and some are not. Apache ActiveMQ, which was chosen as a JMS provider for this example, has the following characteristics:

• the most popular and powerful open-source messaging and Integration Patterns server
• accepts non-Java clients
• can be used standalone in production environments
• supports pluggable transport protocols such as in-VM, TCP, SSL, NIO, UDP, multicast, JGroups, and JXTA transports
• can be used as an in-memory JMS provider, using an embedded broker, to avoid the overhead of running separate processes when doing unit testing JMS5
• the ActiveMQ executable starts with a default configuration
• can also be used embedded in an application
• can be configured using ActiveMQ or Spring configuration (XML or Java Configuration)
• provides advanced messaging features such as message groups, virtual and composite destinations, and wildcards
• provides support for Enterprise Integration Patterns when used with Spring Integration or Apache Camel

What we'll Build

We will build a Spring Boot JMS application that sends User instances wrapped up in JMS Messages to the userQueue.A message listener is configured to process the message and send a confirmation message on the confirmationQueue. Another listener is defined that waiting for the confirmation and printing its contents. To simplify the application even more, there is no need for a producer class and a consumer class. There is only one process that publishes and consumes messages from the two queues. The below diagram shows the Spring Boot JMS application abstract schema:

Create a Spring Boot Application

There are many ways to create a Spring Boot application. The simplest way is to use Spring Initializr at http://start.spring.io/, which is an online Spring Boot application generator.

Maven Dependencies - pom.xml

<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd"> <modelVersion>4.0.0</modelVersion> <groupId>net.javaguides.springboot</groupId> <artifactId>springboot-jms</artifactId> <version>0.1.0</version> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>3.0.4</version> </parent> <properties> <java.version>17</java.version> </properties> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-activemq</artifactId> </dependency> <dependency> <groupId>org.apache.activemq</groupId> <artifactId>activemq-broker</artifactId> </dependency> <dependency> <groupId>com.fasterxml.jackson.core</groupId> <artifactId>jackson-databind</artifactId> </dependency> </dependencies> <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> </plugins> </build> </project> spring-boot-starter-activemq: It provides all the required dependencies to integrate JMS and ActiveMQ with spring boot.activemq-broker : This provides embedded ActiveMQ in the spring boot application. But since we will be configuring our ActiveMQ outside the application we have commented on it for time being.spring-boot-maven-plugin: It will collect all the jar files present in the classpath and create a single executable jar.

Packaging Structure

Following is the packing structure of our Spring boot JMS application -

UserReceiver and ConfirmationReceiver

UserReceiver and ConfirmationReceiver have the responsibility of receiving the user and confirmation messages. The classes have a more practical implementation, making use of the @JmsListener annotation.

UserReceiver.java

package net.javaguides.springboot.jms; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.jms.annotation.JmsListener; import org.springframework.stereotype.Component; import javax.jms.Message; import java.util.concurrent.atomic.AtomicInteger; /** * Created by Ramesh Fadatare */ @Component public class UserReceiver { private Logger logger = LoggerFactory.getLogger(UserReceiver.class); private static AtomicInteger id = new AtomicInteger(); @Autowired ConfirmationSender confirmationSender; @JmsListener(destination = "userQueue", containerFactory = "connectionFactory") public void receiveMessage(User receivedUser, Message message) { logger.info(" >> Original received message: " + message); logger.info(" >> Received user: " + receivedUser); confirmationSender.sendMessage(new Confirmation(id.incrementAndGet(), "User " + receivedUser.getEmail() + " received.")); } }

ConfirmationReceiver.java

The ConfirmationSender class is just a bean with a JmsTemplate bean injected in it that is being used to send a confirmation object to the confirmationQueue. package net.javaguides.springboot.jms; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.jms.annotation.JmsListener; import org.springframework.stereotype.Component; /** * Created by Ramesh Fadatare */ @Component public class ConfirmationReceiver { private Logger logger = LoggerFactory.getLogger(ConfirmationReceiver.class); @JmsListener(destination = "confirmationQueue", containerFactory = "connectionFactory") public void receiveConfirmation(Confirmation confirmation) { logger.info(" >> Received confirmation: " + confirmation); } }

Creating POJO - User and Confirmation

Let's create a simple User.java POJO class that sends over a message queue:

User.java

package net.javaguides.springboot.jms; /** * Created by Ramesh Fadatare */ public class User { private String email; private Double rating; private boolean active; public User() {} public User(String email, Double rating, boolean active) { this.email = email; this.rating = rating; this.active = active; } public String getEmail() { return email; } public void setEmail(String email) { this.email = email; } public Double getRating() { return rating; } public void setRating(Double rating) { this.rating = rating; } public boolean isActive() { return active; } public void setActive(boolean active) { this.active = active; } @Override public String toString() { return "User{" + "email='" + email + '\'' + ", rating=" + rating + ", active=" + active + '}'; } }

Confirmation.java

Let's create Confirmation.java class to confirm whether is message is reviewed on not: package net.javaguides.springboot.jms; /** * Created by Ramesh Fadatare */ public class Confirmation { private int ackNumber; private String verificationComment; public Confirmation() {} public Confirmation(int ackNumber, String verificationComment) { this.ackNumber = ackNumber; this.verificationComment = verificationComment; } public int getAckNumber() { return ackNumber; } public void setAckNumber(int ackNumber) { this.ackNumber = ackNumber; } public String getVerificationComment() { return verificationComment; } public void setVerificationComment(String verificationComment) { this.verificationComment = verificationComment; } @Override public String toString() { return "Confirmation{" + "ackNumber='" + ackNumber + '\'' + ", verificationComment=" + verificationComment + '}'; } }

Send and Receive JMS messages with Spring - Application.java

The Application class is the configuration and starter of the application. It is annotated with the all-powerful @SpringBootApplication, which will make sure to scan for beans in the current package and will inject all infrastructure beans based on the classpath settings. The other annotation on this class is @EnableJms, and as you can probably speculate, this annotation enables the bean postprocessor that will process the @JmsListener annotations and will create the message listener container "under the hood". There is also a converter bean defined as type MappingJackson2MessageConverter implementing the JMS MessageConverter interface that transforms the sent objects into text JSON format. package net.javaguides.springboot; import jakarta.jms.ConnectionFactory; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.boot.autoconfigure.jms.DefaultJmsListenerContainerFactoryConfigurer; import org.springframework.context.ConfigurableApplicationContext; import org.springframework.context.annotation.Bean; import org.springframework.jms.annotation.EnableJms; import org.springframework.jms.config.DefaultJmsListenerContainerFactory; import org.springframework.jms.config.JmsListenerContainerFactory; import org.springframework.jms.core.JmsTemplate; import org.springframework.jms.support.converter.MappingJackson2MessageConverter; import org.springframework.jms.support.converter.MessageConverter; import org.springframework.jms.support.converter.MessageType; import net.javaguides.springboot.jms.User; /** * Created by Ramesh Fadatare */ @SpringBootApplication @EnableJms public class Application { private static Logger logger = LoggerFactory.getLogger(Application.class); public static void main(String[] args) throws Exception { ConfigurableApplicationContext context = SpringApplication.run(Application.class, args); JmsTemplate jmsTemplate = context.getBean(JmsTemplate.class); //Send an user System.out.println("Sending an user message."); jmsTemplate.convertAndSend("userQueue", new User("[email protected]", 5 d, true)); logger.info("Waiting for user and confirmation ..."); System.in.read(); context.close(); } @Bean // Serialize message content to json using TextMessage public MessageConverter jacksonJmsMessageConverter() { MappingJackson2MessageConverter converter = new MappingJackson2MessageConverter(); converter.setTargetType(MessageType.TEXT); converter.setTypeIdPropertyName("_type"); return converter; } @Bean public JmsListenerContainerFactory << ? > connectionFactory(ConnectionFactory connectionFactory, DefaultJmsListenerContainerFactoryConfigurer configurer) { DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory(); // This provides all boot's default to this factory, including the message converter configurer.configure(factory, connectionFactory); // You could still override some of Boot's default if necessary. return factory; } } The JmsTemplate makes it very easy to send messages to destinations, and in this example is automatically created by Spring Boot. The connectionFactory is also created by Spring Boot and is backed up by ActiveMQ running in embedded mode.

Demo

Execute the above Application class’s main() method. The main method, aside from starting up the application, instantiates a JmsTemplate object that is used to send a user object. Clearly, the message was successfully sent and received. That’s all for this quick example of Spring JMSTemplate with embedded ActiveMQ. Related Spring Boot and Microservices Tutorials/Guides: The Hidden Magic of Spring Boot: Secrets Every Developer Should Know What Happens When You Hit a Spring Boot REST API Endpoint (Behind the Scenes) Spring Boot Exception Handling Build CRUD REST API with Spring Boot, Spring Data JPA, Hibernate, and MySQL Spring Boot DELETE REST API: @DeleteMapping Annotation Spring Boot PUT REST API — @PutMapping Annotation Spring Boot POST REST API Spring Boot GET REST API — @GetMapping Annotation Spring Boot REST API with Request Param | Spring Boot Course Spring Boot REST API with Path Variable — @PathVariable Chapter 13: Understanding @SpringBootApplication Annotation | Spring Boot Course Chapter 5: Create Spring Boot Project and Build Hello World REST API | Spring Boot Course 10 Real-World Spring Boot Architecture Tips Every Developer Should Follow Top 10 Spring Boot Tricks Every Java Developer Should Know Debugging Spring Dependency Injection Issues - Very Important Common Code Smells in Spring Applications — How to Fix Them Spring Boot + OpenAI ChatGPT API Integration Tutorial Spring Boot Course -> New Series on Medium ❤️ Spring Boot Microservices with RabbitMQ Example React JS + Spring Boot Microservices Dockerizing a Spring Boot Application How to Change the Default Port in Spring Boot How to Change Context Path in Spring Boot Top 10 Spring Boot REST API Mistakes and How to Avoid Them (2025 Update) Spring Boot REST API Best Practices Spring Boot Security Database Authentication Example Tutorial Spring Boot Security Form-Based Authentication Spring Boot Security In-Memory Authentication What is Spring Boot Really All About? Why Spring Boot over Spring? Top 10 Spring Boot Key Features That You Should Know Spring vs Spring Boot Setting Up the Development Environment for Spring Boot Spring Boot Auto-Configuration: A Quick Guide Spring Boot Starters Quick Guide to Spring Boot Parent Starter Spring Boot Embedded Servers Spring Boot Thymeleaf Hello World Example Chapter 10: Spring Boot DevTools | Spring Boot Course Chapter 13: Spring Boot REST API That Returns JSON | Spring Boot Course Spring Boot REST API That Returns List of Java Objects in JSON Format Top 10 Spring Boot Mistakes and How to Avoid Them Advanced Spring Boot Concepts that Every Java Developer Should Know What Are Microservices in Spring Boot? Integrating React Frontend with Spring Boot ChatGPT API (Step-by-Step Guide) Build a Chatbot Using Spring Boot, React JS, and ChatGPT API Top 10 Mistakes in Spring Boot Microservices and How to Avoid Them (With Examples) Spring Boot Security Best Practices: Protecting Your Application from Attacks 🔄 Dependency Injection in Spring (Explained with Coding Examples) ⚙️ How Spring Container Works Behind the Scenes How Spring Container Works Behind the Scenes (Spring Container Secrets Revealed!) Spring @Component vs @Bean vs @Service vs @Repository Explained How Component Scanning Works Behind the Scenes in Spring How Spring Autowiring Works Internally Top 20 Spring Boot Best Practices for Java Developers Build Spring Boot React Full Stack Project — Todo App [2025 Update] Spring vs Spring MVC vs Spring Boot Spring Boot Best Practices: Use DTOs Instead of Entities in API Responses Spring Boot DTO Tutorial (Using Java record) – Complete CRUD REST API Implementation Spring Boot Architecture: Controller, Service, Repository, Database and Architecture Flow Java Stream filter() Method with Real-World Examples Spring Boot Auto Configuration Explained | How It Works Spring Boot Profiles: How to Manage Environment-Based Configurations Create a Custom Spring Boot Starter | Step-by-Step Guide Spring Boot Starter Modules Explained | Auto-Configuration Guide Deploy Spring Boot Applications with Profile-Based Settings | Step-by-Step Guide Spring Boot Performance Tuning: 10 Best Practices for High Performance Spring Boot @ComponentScan Annotation | Customizing Component Scanning Difference Between @RestController and @RequestMapping in Spring Boot Spring Boot @Cacheable Annotation – Improve Performance with Caching Spring Boot Redis Cache — @Cacheable Complete Guide When to Use @Service, @Repository, @Controller, and @Component Annotations in Spring Boot Why, When, and How to Use @Bean Annotation in Spring Boot App Java Spring Boot vs. Go (Golang) for Backend Development in 2025 Is Autowired Annotation Deprecated in Spring Boot? Everything You Need to Know 🚫 Stop Making These Common Mistakes in Spring Boot Projects Top 10 Mind-Blowing Spring Boot Tricks for Beginners Why Choose Spring Boot Over Spring Framework? | Key Differences and Benefits How to Run a Spring Boot Application | 5 Easy Ways for Developers What is AutoConfiguration in Spring Boot? | Explained with Example Customize Default Configuration in Spring Boot | 5 Proven Ways Chapter 12: Understanding SpringApplication.run() Method Internals | Spring Boot Course What is CommandLineRunner in Spring Boot? How to Create Custom Bean Validation in Spring Boot Can You Build a Non-Web Application with Spring Boot? How to Disable Auto-Configuration in Spring Boot (Step-by-Step Guide) Top 25 Spring Boot Interview Questions and Answers for Beginners How to Use Java Records with Spring Boot Spring Boot Constructor Injection Explained with Step-by-Step Example 🚫 Stop Using @Transactional Everywhere: Understand When You Actually Need It 🚫 Stop Writing Fat Controllers: Follow the Controller-Service-Repository Pattern 🚫 Stop Using Field Injection in Spring Boot: Use Constructor Injection 🚫 Stop Sharing Databases Between Microservices: Use Database Per Service Pattern 10 Java Microservices Best Practices Every Developer Should Follow How to Choose the Right Java Microservices Communication Style (Sync vs Async) How to Implement Event-Driven Communication in Java Microservices (Step-by-Step Guide with Kafka) Stop Building Tight-Coupled Microservices: Aim for Loose Coupling Spring Boot Microservices E-Commerce Project: Step-by-Step Guide Spring Boot Microservices with RabbitMQ Example React JS + Spring Boot Microservices The Ultimate Microservices Roadmap for Beginners: Building Modern Scalable Systems What Are Microservices in Spring Boot? Top 5 Message Brokers Every Developer Should Know Top 10 Spring Cloud Microservices Best Practices [Removed Deprecated Features] Best Tools for Microservices Development in 2025 How to Break a Monolithic Application into Microservices (E-Commerce Use Case) Monoliths Aren’t Dead — Microservices Are Just Overused When to Break a Monolith: A Developer’s Checklist 👑 Java Is Still the King of Microservices — And Here’s the Proof 5 Microservices Design Patterns You Must Know in 2025 Bulkhead Pattern in Microservices — Improve Resilience and Fault Isolation Strangler Fig Pattern in Microservices — Migrate Monolith to Microservices Event Sourcing Pattern in Microservices (With Real-World Example) Circuit Breaker Pattern in Microservices using Spring Boot 3, WebClient and Resilience4j CQRS Pattern in Microservices Aggregator Design Pattern in Microservices — A Complete Guide Database Per Service Pattern in Microservices API Gateway Pattern in Microservices — A Complete Guide Saga Pattern in Microservices: A Step-by-Step Guide Microservices Are a Mess Without These Java Design Patterns️ Java Microservices Interview Questions and Answers for Freshers Top Microservices Interview Questions and Answers for Experienced Professionals Top 10 Microservices Design Pattern Interview Questions and Answers Top Microservices Tricky Interview Questions You Should Know (With Answers) Microservices Best Practices: Building Scalable and Resilient Systems Why Microservices Are the Future of Software Architecture Microservices with Spring Cloud: Simplify Your Architecture Spring Boot and Microservices Roadmap for Beginners [2025 Update] Best Programming Language for Microservices Project Development in 2025 My 50+ Must-Read Microservices Tutorials, Articles and Guides on the Medium Platform Spring Boot

• Get link
• Facebook
• X
• Pinterest
• Email
• Other Apps

Comments

Post a Comment

Leave Comment

Spring Boot 3 Paid Course Published for Free on my Java Guides YouTube Channel

Subscribe to my YouTube Channel (165K+ subscribers): Java Guides Channel

Top 10 My Udemy Courses with Huge Discount: Udemy Courses - Ramesh Fadatare

Close

Master Python Programming and Libraries: Python Full Course

[NEW] Python full course for beginners with essential libraries like NumPy, Pandas, and Matplotlib for data science.

🆕 High-Demand 80–90% OFF

Spring 6 and Spring Boot 3 for Beginners (Includes 6 Projects)

In this course, you will learn Spring Core, Spring Boot 3, REST API, Spring MVC, WebFlux, Spring Security, Spring Data JPA, Docker, Thymeleaf & Building Projects.

🔥 Bestseller 80–90% OFF Available in Udemy for Business

Full-Stack Java Development with Spring Boot 3 and React

In this course, you will build two full-stack web applications (Employee Management System and Todo Management App) using Spring Boot, Spring Security, Spring Data JPA, JWT, React JS, and MySQL database.

🔥 Bestseller 80–90% OFF Available in Udemy for Business

Subscriber to my top YouTube Channel (130K+ Subscribers)

Building Microservices with Spring Boot and Spring Cloud

Learn to build microservices using Spring Boot, Spring Cloud, React, Kafka, RabbitMQ, Docker, and REST API (REST Web Services).

🌟 Top Rated 80–90% OFF Available in Udemy for Business

Premium Member-only Articles

• Read Premium Article on Medium
• Write for Us

Functional Programming in Java (Includes Java Collections)

Learn Java Lambda Expressions, Functional Interfaces, Stream API, and Collections Framework. Write Clean & Concise Code

🎓 Student Favorite 80–90% OFF

Build 5 Spring Boot Projects with Java: Line-by-Line Coding

This course teaches you to build 5+ mini Spring Boot projects using Java 17+, REST API, Spring Boot 3, Spring Security 6, Thymeleaf, React, and MySQL database.

🌟 Top Rated 80–90% OFF

Java Release-wise New Features

Java 8 Features

Java 9 Features

Java 10 Features

Java 11 Features

Java 12 Features

Java 13 Features

Java 14 Features

Java 15 Features

Java 16 Features

Java 17 Features

Java 18 Features

Java 19 Features

Java 20 Features

Java 21 Features

Spring Boot + Apache Kafka Course - The Practical Guide

Learn to use Apache Kafka as a broker to exchange messages between Producer and Consumer in Spring boot applications. 🎓 Student Favorite 80–90% OFF Available in Udemy for Business

ChatGPT + Generative AI + Prompt Engineering for Beginners

Unlock the Power of AI – Learn How to Use ChatGPT, Understand Generative AI, and Master Prompt Writing

🆕 New 80–90% OFF

Testing Spring Boot Application with JUnit and Mockito

In this course, you will learn how to write Unit tests and Integration tests for Spring Boot App using JUnit, Mockito, AssertJ, Hamcrest, JsonPath, & Testcontainers.

🔥 Bestseller 80–90% OFF Available in Udemy for Business

ChatGPT for Java Developers: Boost Your Productivity with AI

Use ChatGPT as a Java developer to code faster, debug smarter, save time, boost productivity, & master AI-powered coding.

🚀 Trending Now 80–90% OFF

Top Udemy Course: Spring Boot Thymeleaf Real-Time Web Application Course

My Udemy Course - Spring Boot RabbitMQ Course - Event-Driven Microservices

My Udemy Course - Master Spring Data JPA with Hibernate

My Udemy Course - Spring Boot + Apache Kafka Course

New Udemy Course: Build 5 Spring Boot Projects with Java: Line-by-Line Coding

About Me

Hi, I am Ramesh Fadatare. I am VMWare Certified Professional for Spring and Spring Boot.

I am the founder and author of this blog website JavaGuides, a technical blog dedicated to the Java/Java EE technologies, Python, Microservices, and Full-Stack Java development.

All the 5K+ articles, guides, and tutorials have been written by me, so contact me if you have any questions/queries. Read more about me at About Me.

Top YouTube Channel (175K+ Subscribers): Check out my YouTube channel for free videos and courses - Java Guides YouTube Channel

My Udemy Courses - My Top and Bestseller Udemy Course

Connect with me on Twitter, Facebook, LinkedIn, GitHub,

Follow Me on Twitter

Follow @FadatareRamesh

Facebook Likes and Shares