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