$show=/label

Spring Boot ActiveMQ In Memory Example - Publisher Consumer

SHARE:

A quick guide to how to publish and consume the messages using ActiveMQ In memory in Spring Boot. This is a inmemory example for Publisher and Consumer (Listener) Example.

1. Introduction


In this article, You will learn how to Create an ActiveMQ Inmemory publisher and consumer model example in Spring Boot.

All the messages that are pushed to the queue will be stored in the memory rather than storing into the database. In the next article,  you can find out "Spring Boot with Standalone ActiveMQ Example"

Spring Boot ActiveMQ InMemory Example - Publisher Consumer


For today's example, you are not required to have active MQ in your local machine. Because we are storing the messages in memory with spring boot in-memory Active MQ.


2. Spring Boot ActiveMQ In memory Application Creation


First, let us create a spring boot application along with the required dependencies. Spring Boot application can be created from spring boot init link.

Add Spring Web and Apache ActiveMQ 5 dependencies in the dependency section then it generates the application with all needed structure.

Spring Boot ActiveMQ Application Creation


Now, the spring boot Active MQ demo project is created and now open from IDE.

3. Spring Boot ActiveMQ In memory Maven Set Up


Next, Verify the all jars are added to the pom.xml file.

These two dependent jars should be present in the pom.xml file

spring-boot-starter-activemq and spring-boot-starter-web



<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
 <modelVersion>4.0.0</modelVersion>
 <parent>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-parent</artifactId>
  <version>2.2.6.RELEASE</version>
  <relativePath/> <!-- lookup parent from repository -->
 </parent>
 <groupId>com.javaprogramto.spring.boot</groupId>
 <artifactId>activemq-demo</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 <name>activemq-demo</name>
 <description>Demo project for Spring Boot</description>

 <properties>
  <java.version>1.8</java.version>
 </properties>

 <dependencies>
  <dependency>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-activemq</artifactId>
  </dependency>
  <dependency>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-web</artifactId>
  </dependency>

  <dependency>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-test</artifactId>
   <scope>test</scope>
   <exclusions>
    <exclusion>
     <groupId>org.junit.vintage</groupId>
     <artifactId>junit-vintage-engine</artifactId>
    </exclusion>
   </exclusions>
  </dependency>
 </dependencies>

 <build>
  <plugins>
   <plugin>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-maven-plugin</artifactId>
   </plugin>
  </plugins>
 </build>

</project>




Internally,  spring-boot-starter-activemq dependency is dependent on spring-jms and activemq-broker jars.

4. Spring Boot ActiveMQ In memory Configurations


Another main configuration is about creating Inmemory Queue and register with the application context.

The queue is created with the name of "local.inmemory.queue" and also you must add @EnableJMS annotation on the configuration class or spring boot main application.

ActiveMQQueue class will create a new queue if does not exist with the name given.

[package com.javaprogramto.spring.boot.activemqdemo.config; import org.apache.activemq.command.ActiveMQQueue; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.jms.annotation.EnableJms; import javax.jms.Queue; @EnableJms@Configurationpublic class ActiveMQConfiguration { @Bean public Queue createQueue(){ return new ActiveMQQueue("local.inmemory.queue"); } }]




5. Creating Publisher Implementation for In memory ActiveMQ

[package com.javaprogramto.spring.boot.activemqdemo.publisher;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.jms.Queue;

@RequestMapping("/api/publish")
@RestControllerpublic class PublisherImpl {

Logger logger = LoggerFactory.getLogger(getClass());

@Autowired private JmsTemplate jmsTemplate;

@Autowired private Queue queue;

@GetMapping("/{msg}")
public String publishMessage(@PathVariable("msg") String content ){
jmsTemplate.convertAndSend(queue, content);
logger.info("Message published : "+content);
return "Success";
}
}]

6. Creating Consumer Implementation for In memory ActiveMQ

[package com.javaprogramto.spring.boot.activemqdemo.consumer;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Component;

@Componentpublic class ConsumerImpl {

Logger logger = LoggerFactory.getLogger(getClass());

@JmsListener(destination = "local.inmemory.queue")
public void onMessage(String content){

logger.info("Message received : "+content);

}
}]

7. Spring Boot In memory ActiveMQ application.properties

Explicitly, you need to tell to spring to use the in-memory active MQ instead of using locally installed one. To enable, inbuild active MQ set the property value spring.activemq.in-memory to true.



8. Run & Test Application 


Just run the main application of spring boot.
spring.activemq.in-memory=true
spring.activemq.pool.enabled=false
server.port=8082

[package com.javaprogramto.spring.boot.activemqdemo;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplicationpublic class ActivemqDemoApplication {
public static void main(String[] args) {

SpringApplication.run(ActivemqDemoApplication.class, args);

}
}]

Hit the endpoint after successfully starting the application.

http://localhost:8082/api/publish/message1
http://localhost:8082/api/publish/message2
http://localhost:8082/api/publish/message3
http://localhost:8082/api/publish/message4
http://localhost:8082/api/publish/message5

Here, we've hit the service 5 times sending the different messages.

[2020-04-29 22:14:02.100  INFO 25369 --- [           main] c.j.s.b.a.ActivemqDemoApplication        : Started ActivemqDemoApplication in 1.992 seconds (JVM running for 2.626)
2020-04-29 22:14:04.989  INFO 25369 ---  : Initializing Spring DispatcherServlet 'dispatcherServlet'
2020-04-29 22:14:04.990  INFO 25369 ---  : Initializing Servlet 'dispatcherServlet'
2020-04-29 22:14:04.998  INFO 25369 ---  : Completed initialization in 8 ms
2020-04-29 22:14:05.039  INFO 25369 ---  : Message published : message1
2020-04-29 22:14:05.045  INFO 25369 ---  : Message received : message1
2020-04-29 22:14:12.682  INFO 25369 ---  : Message published : message2
2020-04-29 22:14:12.683  INFO 25369 ---  : Message received : message2
2020-04-29 22:14:16.536  INFO 25369 ---  : Message published : message3
2020-04-29 22:14:16.536  INFO 25369 ---  : Message received : message3
2020-04-29 22:14:19.098  INFO 25369 ---  : Message published : message4
2020-04-29 22:14:19.098  INFO 25369 ---  : Message received : message4
2020-04-29 22:14:21.386  INFO 25369 ---  : Message published : message5
2020-04-29 22:14:21.386  INFO 25369 ---  : Message received : message5]

You can see all the messages published and consumed from the queue.

9. Conclusion

In conclusion, You've seen how to send and received the messages from Spring Boot Active MQ in-memory queue.

All the code is shown in this article is over GitHub.

You can download the project directly and can run in your local without any errors.


[View on GitHub ##eye##]

[Download ##file-download##]



If you have any queries in building this application please post in the comment section.

Spring Boot ActiveMQ InMemory Example

COMMENTS

BLOGGER

About Us

Author: Venkatesh - I love to learn and share the technical stuff.
Name

accumulo,1,ActiveMQ,2,Adsense,1,API,31,ArrayList,16,Arrays,2,Bean Creation,3,Bean Scopes,1,BiConsumer,1,Blogger Tips,1,Books,1,C Programming,1,Collection,4,Collections,20,Collector,1,Command Line,1,Compile Errors,1,Configurations,7,Constants,1,Control Statements,8,Conversions,5,Core Java,72,Corona India,1,Create,2,CSS,1,Date,2,Date Time API,3,Dictionary,1,Difference,1,Download,1,Eclipse,2,Efficiently,1,Error,1,Errors,1,Exception,1,Exceptions,2,Fast,1,Files,9,Float,1,Font,1,For examples,1,For loop examples,1,For Loop in Java,1,Form,1,Freshers,1,Function,3,Functional Interface,2,Garbage Collector,1,Generics,4,Git,4,Grant,1,Grep,1,HashMap,1,HTML,2,HttpClient,2,Immutable,1,Inner for loops,1,Installation,1,Interview Questions,5,Iterate,2,Jackson API,3,Java,28,Java 10,1,Java 11,5,Java 12,5,Java 13,2,Java 14,2,java 5 For loop,1,Java 8,48,Java 9,1,Java Design Patterns,1,Java Files,1,Java for loop,1,Java Program,2,Java Programs,65,java.lang,5,java.util. function,1,jQuery,1,Kotlin,10,Kotlin Programs,6,Lambda,1,lang,29,Leap Year,1,live updates,1,Math,1,Maven,1,Method References,1,Mockito,1,MongoDB,3,Nested for loop,1,Nested for loop examples,1,New Features,1,Operations,1,Optional,4,Oracle,5,Oracle 18C,1,Partition,1,Patterns,1,Programs,1,Property,1,Python,2,Quarkus,1,Read,1,Real Time,1,Recursion,2,Remove,2,Rest API,1,Schedules,1,Serialization,1,Servlet,1,Softwares,1,Sorting Techniques,8,Spring,2,Spring Boot,23,Spring Email,1,Spring MVC,1,Stream,3,Streams,11,String,48,String Programs,8,String Revese,1,Swing,1,System,1,Tags,1,Threads,8,Tomcat,1,Tomcat 8,1,Troubleshoot,16,Unix,2,Updates,3,util,5,While Loop,1,
ltr
item
JavaProgramTo.com: Spring Boot ActiveMQ In Memory Example - Publisher Consumer
Spring Boot ActiveMQ In Memory Example - Publisher Consumer
A quick guide to how to publish and consume the messages using ActiveMQ In memory in Spring Boot. This is a inmemory example for Publisher and Consumer (Listener) Example.
https://1.bp.blogspot.com/-oIj-ul3BT50/XqnN_T-fUKI/AAAAAAAAClU/vAoViqVwdmIQcsYVvtlZu6jhKpRf54jeQCLcBGAsYHQ/s640/Spring%2BBoot%2BActiveMQ%2BInMemory%2BExample%2B-%2BPublisher%2BConsumer.png
https://1.bp.blogspot.com/-oIj-ul3BT50/XqnN_T-fUKI/AAAAAAAAClU/vAoViqVwdmIQcsYVvtlZu6jhKpRf54jeQCLcBGAsYHQ/s72-c/Spring%2BBoot%2BActiveMQ%2BInMemory%2BExample%2B-%2BPublisher%2BConsumer.png
JavaProgramTo.com
https://www.javaprogramto.com/2020/04/spring-boot-activemq-in-memory-example.html
https://www.javaprogramto.com/
https://www.javaprogramto.com/
https://www.javaprogramto.com/2020/04/spring-boot-activemq-in-memory-example.html
true
3124782013468838591
UTF-8
Loaded All Posts Not found any posts VIEW ALL Readmore Reply Cancel reply Delete By Home PAGES POSTS View All RECOMMENDED FOR YOU LABEL ARCHIVE SEARCH ALL POSTS Not found any post match with your request Back Home Sunday Monday Tuesday Wednesday Thursday Friday Saturday Sun Mon Tue Wed Thu Fri Sat January February March April May June July August September October November December Jan Feb Mar Apr May Jun Jul Aug Sep Oct Nov Dec just now 1 minute ago $$1$$ minutes ago 1 hour ago $$1$$ hours ago Yesterday $$1$$ days ago $$1$$ weeks ago more than 5 weeks ago Followers Follow THIS PREMIUM CONTENT IS LOCKED STEP 1: Share to a social network STEP 2: Click the link on your social network Copy All Code Select All Code All codes were copied to your clipboard Can not copy the codes / texts, please press [CTRL]+[C] (or CMD+C with Mac) to copy Table of Content