JMS implementation in Spring Boot

Posted By :Rozi Ali |31st January 2021

JMS(Java Message Service)  is a API provided by java to create, send and read messages. It provide both point-to-point and publish-subscribe messaging models. In this blog we will talk about JMS implementation using Spring Boot.

To create and manage message queue, we will use Apache Active MQ which enables applications to exchange messages asynchronously.

Maven dependencies required are:



Now lets create a message receiver that picks the message from the queue.

import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Component;
public class Receiver {
    @JmsListener(destination = "msgQueue")
    public void receiveMessage(Message message) 
        System.out.println("Message Received " + message );

Here, @JmsListener is used to mark Receiver class to be the target of JMS Message Listener of provided destination ("msgQueue")


Here, Message class is a DTO.

public class Message implements Serializable {
    private Long id;
    private String msg;
    public Long getId() {
        return id;
    public void setId(Long id) { = id;
    public String getMsg() {
        return content;
    public void setMsg(String msg) {
        this.msg = msg;

    public String toString() {
	return "Message [id=" + id + ", msg=" + msg"]";


Now, to create a sender, i am creating a rest API

import org.springframework.jms.core.JmsTemplate;

public class MessageSender{
	private JmsTemplate jmsTemplate;

	public void send(@RequestBody Message message){
		System.out.println("Sending message...");
		jmsTemplate.convertAndSend("msgQueue", message);

here, JmsTemplate is used, it is a helper class that helps to send or receive messages through JMS. It's convertAndSend() function converts object into message and sends it to the provided destination.


In the final step, we add @EnableJms and create JmsListenerContainerFactory in main method

import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.autoconfigure.jms.DefaultJmsListenerContainerFactoryConfigurer;
import org.springframework.context.annotation.Bean;
import org.springframework.jms.annotation.EnableJms;
import org.springframework.jms.config.DefaultJmsListenerContainerFactory;
import org.springframework.jms.config.JmsListenerContainerFactory;
public class JMSDemo 
    public JmsListenerContainerFactory<?> myFactory(
                            ConnectionFactory connectionFactory,
                            DefaultJmsListenerContainerFactoryConfigurer configurer) 
        DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
        configurer.configure(factory, connectionFactory);
        return factory;
    public MessageConverter JmsMessageConverter() 
        MappingJackson2MessageConverter converter = new MappingJackson2MessageConverter();
        return converter;

JmsListenerContainerFactory is responsible to create listener container. DefaultJmsListenerContainerFactory contains necessary configurations that are supported by the MessageListenerContainer.

About Author

Rozi Ali

Rozi Ali is an accomplished software developer with extensive experience in the field of JAVA. She possesses a solid grasp of programming languages such as Java/Spring-boot, Python, and Typescript/Nodejs/GraphQL. Rozi has a strong background in Object-oriented programming (OOP) and is skilled in working with both relational databases like MySql, PostgreSQL and non-relational databases like MongoDb. She is proficient in REST APIs, Microservices, and code deployment, along with the development tools such as Jira, Git, and Bash. Additionally, Rozi has experience working with Cloud providers such as AWS and Azure. She has contributed significantly to a number of projects, including Konfer, VNS, Influsoft, VN Platform, QuickDialog, and Oodles-Dashboard.

Request For Proposal

[contact-form-7 404 "Not Found"]

Ready to innovate ? Let's get in touch

Chat With Us