From 5bb2adb42501609efaf5e687f3a825cc133059cb Mon Sep 17 00:00:00 2001
From: lihongjie0209 <lihongjie0209@gmail.com>
Date: Mon, 13 May 2024 15:56:17 +0800
Subject: [PATCH] =?UTF-8?q?=E8=BF=81=E7=A7=BB=E5=88=B0=E6=9C=AC=E5=9C=B0do?=
 =?UTF-8?q?cker?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 README.md                                             |  9 +++++++++
 .../cn/lihongjie/coal/rabbitmq/RabbitMQService.java   | 11 ++++++++---
 2 files changed, 17 insertions(+), 3 deletions(-)

diff --git a/README.md b/README.md
index e1a9bda4..cd8465fc 100644
--- a/README.md
+++ b/README.md
@@ -83,6 +83,13 @@ cd /data/backup && sudo -u postgres  pg_dumpall | gzip > /data/backup/$(date +"%
 
 ```
 
+rabbitmq 初始化
+
+```
+rabbitmq add_vhost /coal
+
+
+```
 
 
 添加数据采集rabbitmq用户
@@ -98,6 +105,8 @@ rabbitmqctl set_permissions --vhost /coal/test datacollector '' 'sysExchange' 'p
 ```
 
 
+
+
 本地端口映射
 
 
diff --git a/src/main/java/cn/lihongjie/coal/rabbitmq/RabbitMQService.java b/src/main/java/cn/lihongjie/coal/rabbitmq/RabbitMQService.java
index f7c4dbd7..6ff84c3a 100644
--- a/src/main/java/cn/lihongjie/coal/rabbitmq/RabbitMQService.java
+++ b/src/main/java/cn/lihongjie/coal/rabbitmq/RabbitMQService.java
@@ -10,9 +10,11 @@ import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.MapUtils;
 import org.springframework.amqp.core.MessageListener;
 import org.springframework.amqp.core.Queue;
+import org.springframework.amqp.core.TopicExchange;
 import org.springframework.amqp.rabbit.core.RabbitTemplate;
 import org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.context.support.GenericApplicationContext;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.support.TransactionSynchronization;
@@ -25,6 +27,10 @@ import java.util.Map;
 @Slf4j
 public class RabbitMQService {
 
+    @Autowired
+    @Qualifier("topicExchange")
+    TopicExchange sysExchange;
+
     @Autowired RabbitTemplate rabbitTemplate;
 
     @PersistenceContext EntityManager em;
@@ -84,14 +90,14 @@ public class RabbitMQService {
         container.setConcurrency("1");
         container.setMessageListener(messageListener);
 
-        applicationContext.registerBean("container." + queue.getName(),
+        applicationContext.registerBean(
+                "container." + queue.getName(),
                 SimpleMessageListenerContainer.class,
                 () -> container,
                 bd -> {
                     bd.setInitMethodName("start");
                     bd.setDestroyMethodName("stop");
                     bd.setLazyInit(false);
-
                 });
     }
 
@@ -99,7 +105,6 @@ public class RabbitMQService {
 
         Runnable command =
                 () -> {
-
                     log.info("send to exchange: {} {}", exchange, routingKey);
 
                     rabbitTemplate.convertAndSend(