新增mq

hsweb-web-message/src/main/java/org/hsweb/web/message/MessageHolder.java

@@ -0,0 +1,8 @@
+package org.hsweb.web.message;
+
+/**
+ * @author zhouhao
+ */
+public class MessageHolder {
+
+}

hsweb-web-message/src/test/java/org/hsweb/web/message/AmqpTests.java

@@ -5,9 +5,16 @@ import org.junit.runner.RunWith;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.jms.annotation.EnableJms;
+import org.springframework.jms.config.JmsListenerContainerFactory;
+import org.springframework.jms.config.SimpleJmsListenerEndpoint;
 import org.springframework.jms.core.JmsMessagingTemplate;
+import org.springframework.jms.core.JmsTemplate;
+import org.springframework.jms.listener.MessageListenerContainer;
+import org.springframework.messaging.simp.annotation.SendToUser;
 import org.springframework.test.context.junit4.SpringRunner;
 
+import javax.jms.*;
+import javax.jms.Message;
 import java.util.HashMap;
 
 
@@ -20,11 +27,16 @@ import java.util.HashMap;
 public class AmqpTests {
 
     @Autowired
-    private JmsMessagingTemplate jmsMessagingTemplate;
+    private JmsTemplate template;
 
     @Test
-    public void testSend() {
-        jmsMessagingTemplate.convertAndSend("test", new HashMap<>());
+    public void testSend() throws InterruptedException {
+
+        for (int i = 0; i < 100; i++) {
+            template.convertAndSend("test2", "aaaa" + i);
+        }
+        Thread.sleep(10000);
+
     }
 
 }

hsweb-web-message/src/test/java/org/hsweb/web/message/Consumer.java

@@ -1,14 +1,21 @@
 package org.hsweb.web.message;
 
 import org.springframework.jms.annotation.JmsListener;
+import org.springframework.messaging.simp.annotation.SubscribeMapping;
 import org.springframework.stereotype.Component;
 
 @Component
 public class Consumer {
 
-	@JmsListener(destination = "test")
-    public void receiveQueue(String text) {
-		System.out.println(text);
-	}
+
+    @JmsListener(destination = "test2")
+    public void receiveQueue3(String text) {
+        System.out.println("3:" + text);
+    }
+
+    @JmsListener(destination = "test2")
+    public void receiveQueue4(String text) {
+        System.out.println("4:" + text);
+    }
 
 }

hsweb-web-message/src/test/java/org/hsweb/web/message/SampleActiveMQApplication.java

@@ -1,21 +1,29 @@
 package org.hsweb.web.message;
 
-import javax.jms.Queue;
-
 import org.apache.activemq.command.ActiveMQQueue;
-
-import org.springframework.boot.SpringApplication;
+import org.apache.activemq.command.ActiveMQTopic;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.context.annotation.Bean;
 import org.springframework.jms.annotation.EnableJms;
+import org.springframework.jms.listener.adapter.MessageListenerAdapter;
+
+import javax.jms.MessageListener;
+import javax.jms.Queue;
+import javax.jms.Topic;
 
 @SpringBootApplication
 @EnableJms
 public class SampleActiveMQApplication {
 
-	@Bean
+    @Bean
     public Queue queue() {
-		return new ActiveMQQueue("test");
-	}
+        return new ActiveMQQueue("test");
+    }
+
+    @Bean
+    public Topic topic() {
+        ActiveMQTopic topic = new ActiveMQTopic("test2");
+        return topic;
+    }
 
 }

hsweb-web-message/src/test/resources/application.yml

@@ -1,3 +1,6 @@
 spring:
     activemq:
-        in-memory: true
+        in-memory: false
+        pool:
+          enabled: false
+        broker-url: failover:tcp://127.0.0.1:61616