Spring Boot ActiveMQ JMS

Author: Urunov

Part-7 Spring Boot TEST/5.SpringBoot-JMS-ActiveMQ-Logback/pom.xml

@@ -38,6 +38,12 @@
  <artifactId>spring-boot-starter-test</artifactId>
  <scope>test</scope>
  </dependency>
+ <dependency>
+ <groupId>org.springframework.boot</groupId>
+ <artifactId>spring-boot-starter-web</artifactId>
+ <version>RELEASE</version>
+ <scope>compile</scope>
+ </dependency>
  </dependencies>
 
  <build>

Part-7 Spring Boot TEST/5.SpringBoot-JMS-ActiveMQ-Logback/src/main/java/com/urunov/jmsactivemq/config/Config.java

@@ -0,0 +1,34 @@
+package com.urunov.jmsactivemq.config;
+
+import org.apache.activemq.ActiveMQConnectionFactory;
+import org.apache.activemq.command.ActiveMQQueue;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.jms.core.JmsTemplate;
+
+import java.util.Queue;
+
+@Configuration
+public class Config {
+ //
+ @Value("${activemq.broker-url}")
+ private String brokerUrl;
+ @Bean
+ public Queue queue() {
+ return (Queue) new ActiveMQQueue("standalone.queue");
+ }
+
+ @Bean
+ public ActiveMQConnectionFactory activeMQConnectionFactory() {
+ ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory();
+ factory.setBrokerURL(brokerUrl);
+
+ return factory;
+ }
+
+ @Bean
+ public JmsTemplate jmsTemplate(){
+ return new JmsTemplate(activeMQConnectionFactory());
+ }
+}

Part-7 Spring Boot TEST/5.SpringBoot-JMS-ActiveMQ-Logback/src/main/java/com/urunov/jmsactivemq/listener/Consumer.java

@@ -0,0 +1,13 @@
+package com.urunov.jmsactivemq.listener;
+
+import org.springframework.jms.annotation.JmsListener;
+import org.springframework.stereotype.Component;
+
+@Component
+public class Consumer {
+ //
+ @JmsListener(destination = "standalone.queue")
+ public void consume(String message){
+ System.out.println("Received Message" + message);
+ }
+}

Part-7 Spring Boot TEST/5.SpringBoot-JMS-ActiveMQ-Logback/src/main/java/com/urunov/jmsactivemq/resource/ProducerResource.java

@@ -0,0 +1,28 @@
+package com.urunov.jmsactivemq.resource;
+
+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.Destination;
+import java.util.Queue;
+
+@RestController
+@RequestMapping("/rest/publish")
+public class ProducerResource {
+ //
+ @Autowired
+ JmsTemplate jmsTemplate;
+
+ @Autowired
+ Queue queue;
+
+ @GetMapping("/message")
+ public String publish(@PathVariable("message") final String message){
+ jmsTemplate.convertAndSend((Destination) queue, message);
+ return "Published Successfully";
+ }
+}

Part-7 Spring Boot TEST/5.SpringBoot-JMS-ActiveMQ-Logback/src/main/resources/application.properties

@@ -1 +1,5 @@
 
+spring.activemq.in-memory=false
+spring.activemq.pool.enabled=false
+server.port=8081
+spring.activemq.broker-url=tcp://localhost:61616