增加 activemq 示例

Author: YunaiV

lab-32/lab-32-activemq-demo-message-model/src/main/java/cn/iocoder/springboot/lab32/activemqdemo/config/RabbitConfig.java renamed to lab-32/lab-32-activemq-demo-message-model/src/main/java/cn/iocoder/springboot/lab32/activemqdemo/config/ActiveMQConfig.java

@@ -1,9 +1,5 @@
 package cn.iocoder.springboot.lab32.activemqdemo.config;
 
-import cn.iocoder.springboot.lab32.activemqdemo.message.BroadcastMessage;
-import cn.iocoder.springboot.lab32.activemqdemo.message.ClusteringMessage;
-import org.apache.activemq.command.ActiveMQQueue;
-import org.apache.activemq.command.ActiveMQTopic;
 import org.springframework.boot.autoconfigure.jms.DefaultJmsListenerContainerFactoryConfigurer;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
@@ -12,24 +8,17 @@
 import org.springframework.jms.core.JmsTemplate;
 
 import javax.jms.ConnectionFactory;
-import javax.jms.Queue;
-import javax.jms.Topic;
 
 @Configuration
-public class RabbitConfig {
+public class ActiveMQConfig {
 
     public static final String CLUSTERING_JMS_LISTENER_CONTAINER_FACTORY_BEAN_NAME = "clusteringJmsListenerContainerFactory";
     public static final String BROADCAST_JMS_LISTENER_CONTAINER_FACTORY_BEAN_NAME = "broadcastJmsListenerContainerFactory";
 
     public static final String CLUSTERING_JMS_TEMPLATE_BEAN_NAME = "clusteringJmsTemplate";
     public static final String BROADCAST_JMS_TEMPLATE_BEAN_NAME = "broadcastJmsTemplate";
 
-    // ========== 集群消费 ==========
-
-    @Bean
-    public Queue clusteringQueue() {
-        return new ActiveMQQueue(ClusteringMessage.QUEUE);
-    }
+    // ========== 集群消费 =========
 
     @Bean(CLUSTERING_JMS_LISTENER_CONTAINER_FACTORY_BEAN_NAME)
     public DefaultJmsListenerContainerFactory clusteringJmsListenerContainerFactory(
@@ -51,11 +40,6 @@ public JmsMessagingTemplate clusteringJmsTemplate(ConnectionFactory connectionFa
 
     // ========== 广播消费 ==========
 
-    @Bean
-    public Topic broadcastTopic() {
-        return new ActiveMQTopic(BroadcastMessage.TOPIC);
-    }
-
     @Bean(BROADCAST_JMS_LISTENER_CONTAINER_FACTORY_BEAN_NAME)
     public DefaultJmsListenerContainerFactory broadcastJmsListenerContainerFactory(
             DefaultJmsListenerContainerFactoryConfigurer configurer, ConnectionFactory connectionFactory) {

lab-32/lab-32-activemq-demo-message-model/src/main/java/cn/iocoder/springboot/lab32/activemqdemo/consumer/BroadcastConsumer.java

@@ -1,6 +1,6 @@
 package cn.iocoder.springboot.lab32.activemqdemo.consumer;
 
-import cn.iocoder.springboot.lab32.activemqdemo.config.RabbitConfig;
+import cn.iocoder.springboot.lab32.activemqdemo.config.ActiveMQConfig;
 import cn.iocoder.springboot.lab32.activemqdemo.message.BroadcastMessage;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -13,7 +13,7 @@ public class BroadcastConsumer {
     private Logger logger = LoggerFactory.getLogger(getClass());
 
     @JmsListener(destination = BroadcastMessage.TOPIC,
-            containerFactory = RabbitConfig.BROADCAST_JMS_LISTENER_CONTAINER_FACTORY_BEAN_NAME)
+            containerFactory = ActiveMQConfig.BROADCAST_JMS_LISTENER_CONTAINER_FACTORY_BEAN_NAME)
     public void onMessage(BroadcastMessage message) {
         logger.info("[onMessage][线程编号:{} 消息内容：{}]", Thread.currentThread().getId(), message);
     }

lab-32/lab-32-activemq-demo-message-model/src/main/java/cn/iocoder/springboot/lab32/activemqdemo/consumer/ClusteringConsumer.java

@@ -1,6 +1,6 @@
 package cn.iocoder.springboot.lab32.activemqdemo.consumer;
 
-import cn.iocoder.springboot.lab32.activemqdemo.config.RabbitConfig;
+import cn.iocoder.springboot.lab32.activemqdemo.config.ActiveMQConfig;
 import cn.iocoder.springboot.lab32.activemqdemo.message.ClusteringMessage;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -13,7 +13,7 @@ public class ClusteringConsumer {
     private Logger logger = LoggerFactory.getLogger(getClass());
 
     @JmsListener(destination = ClusteringMessage.QUEUE,
-            containerFactory = RabbitConfig.CLUSTERING_JMS_LISTENER_CONTAINER_FACTORY_BEAN_NAME)
+            containerFactory = ActiveMQConfig.CLUSTERING_JMS_LISTENER_CONTAINER_FACTORY_BEAN_NAME)
     public void onMessage(ClusteringMessage message) {
         logger.info("[onMessage][线程编号:{} 消息内容：{}]", Thread.currentThread().getId(), message);
     }

lab-32/lab-32-activemq-demo-message-model/src/main/java/cn/iocoder/springboot/lab32/activemqdemo/producer/BroadcastProducer.java

@@ -1,6 +1,6 @@
 package cn.iocoder.springboot.lab32.activemqdemo.producer;
 
-import cn.iocoder.springboot.lab32.activemqdemo.config.RabbitConfig;
+import cn.iocoder.springboot.lab32.activemqdemo.config.ActiveMQConfig;
 import cn.iocoder.springboot.lab32.activemqdemo.message.BroadcastMessage;
 import org.springframework.jms.core.JmsMessagingTemplate;
 import org.springframework.stereotype.Component;
@@ -10,7 +10,7 @@
 @Component
 public class BroadcastProducer {
 
-    @Resource(name = RabbitConfig.BROADCAST_JMS_TEMPLATE_BEAN_NAME)
+    @Resource(name = ActiveMQConfig.BROADCAST_JMS_TEMPLATE_BEAN_NAME)
     private JmsMessagingTemplate jmsMessagingTemplate;
 
     public void syncSend(Integer id) {

lab-32/lab-32-activemq-demo-message-model/src/main/java/cn/iocoder/springboot/lab32/activemqdemo/producer/ClusteringProducer.java

@@ -1,6 +1,6 @@
 package cn.iocoder.springboot.lab32.activemqdemo.producer;
 
-import cn.iocoder.springboot.lab32.activemqdemo.config.RabbitConfig;
+import cn.iocoder.springboot.lab32.activemqdemo.config.ActiveMQConfig;
 import cn.iocoder.springboot.lab32.activemqdemo.message.ClusteringMessage;
 import org.springframework.jms.core.JmsMessagingTemplate;
 import org.springframework.stereotype.Component;
@@ -10,7 +10,7 @@
 @Component
 public class ClusteringProducer {
 
-    @Resource(name = RabbitConfig.CLUSTERING_JMS_TEMPLATE_BEAN_NAME)
+    @Resource(name = ActiveMQConfig.CLUSTERING_JMS_TEMPLATE_BEAN_NAME)
     private JmsMessagingTemplate rabbitTemplate;
 
     public void syncSend(Integer id) {