spring-boot-starter-activemq

whatsmars-mq/pom.xml

@@ -42,17 +42,19 @@
             <version>1.1.0-RELEASE</version>
         </dependency>
 
-        <dependency>
-            <groupId>org.springframework</groupId>
-            <artifactId>spring-jms</artifactId>
-        </dependency>
         <dependency>
             <groupId>org.apache.activemq</groupId>
-            <artifactId>activemq-client</artifactId>
+            <artifactId>activemq-all</artifactId>
         </dependency>
         <dependency>
-            <groupId>org.apache.activemq</groupId>
-            <artifactId>activemq-all</artifactId>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-activemq</artifactId>
+            <exclusions>
+                <exclusion>
+                    <groupId>org.apache.activemq</groupId>
+                    <artifactId>activemq-broker</artifactId>
+                </exclusion>
+            </exclusions>
         </dependency>
 
         <dependency>

whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/activemq/boot/ActiveMQApplication.java

+package org.hongxi.whatsmars.mq.activemq.boot;
+
+import org.apache.activemq.command.ActiveMQQueue;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.context.annotation.Bean;
+import org.springframework.jms.annotation.EnableJms;
+
+import javax.jms.Queue;
+
+/**
+ * Created by shenhongxi on 2018/1/16.
+ */
+@SpringBootApplication
+@EnableJms
+public class ActiveMQApplication {
+    public static void main(String[] args) {
+        SpringApplication.run(ActiveMQApplication.class);
+    }
+
+    @Bean
+    public Queue queue() {
+        return new ActiveMQQueue("sample.queue");
+    }
+}

whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/activemq/boot/Consumer.java

+package org.hongxi.whatsmars.mq.activemq.boot;
+
+import org.springframework.jms.annotation.JmsListener;
+import org.springframework.stereotype.Component;
+
+@Component
+public class Consumer {
+
+	@JmsListener(destination = "sample.queue")
+	public void receiveQueue(String text) {
+		System.out.println(text);
+	}
+
+}
\ No newline at end of file

whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/activemq/boot/Producer.java

+package org.hongxi.whatsmars.mq.activemq.boot;
+
+import javax.jms.Queue;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.CommandLineRunner;
+import org.springframework.jms.core.JmsMessagingTemplate;
+import org.springframework.stereotype.Component;
+
+@Component
+public class Producer implements CommandLineRunner {
+
+	@Autowired
+	private JmsMessagingTemplate jmsMessagingTemplate;
+
+	@Autowired
+	private Queue queue;
+
+	@Override
+	public void run(String... args) throws Exception {
+		send("Sample message");
+		System.out.println("Message was sent to the Queue");
+	}
+
+	public void send(String msg) {
+		this.jmsMessagingTemplate.convertAndSend(this.queue, msg);
+	}
+
+}
\ No newline at end of file

whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/activemq/spring/DemoMessageListener.java

 package org.hongxi.whatsmars.mq.activemq.spring;
 
-import org.apache.activemq.ActiveMQConnectionFactory;
 import org.springframework.stereotype.Service;
 
 import javax.jms.*;

whatsmars-mq/src/main/resources/application.yml

@@ -2,4 +2,6 @@ spring:
   rocketmq:
     name-server: 127.0.0.1:9876
     producer:
-      group: boot_producer_group
\ No newline at end of file
+      group: boot_producer_group
+  activemq:
+    brokerUrl: tcp://127.0.0.1:61616
\ No newline at end of file