From 5a48adc1533403e6f2dbdb500220b5bac01ff916 Mon Sep 17 00:00:00 2001
From: beeajax <1105173470@qq.com>
Date: Thu, 8 Jun 2023 22:19:40 +0800
Subject: [PATCH] =?UTF-8?q?=E8=A2=AB=E5=8A=A8rabbitmq=E6=A8=A1=E6=9D=BF?=
 =?UTF-8?q?=E5=B0=81=E8=A3=85?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../docus/server/collect/basic/mq/RabbitMqBasicConsumer.java  | 4 ++--
 .../docus/server/collect/dept/mq/RabbitMqDeptConsumer.java    | 4 ++--
 .../docus/server/collect/user/mq/RabbitMqUserConsumer.java    | 4 ++--
 3 files changed, 6 insertions(+), 6 deletions(-)

diff --git a/collect-sdry/src/main/java/com/docus/server/collect/basic/mq/RabbitMqBasicConsumer.java b/collect-sdry/src/main/java/com/docus/server/collect/basic/mq/RabbitMqBasicConsumer.java
index 60dff5c..9af42fe 100644
--- a/collect-sdry/src/main/java/com/docus/server/collect/basic/mq/RabbitMqBasicConsumer.java
+++ b/collect-sdry/src/main/java/com/docus/server/collect/basic/mq/RabbitMqBasicConsumer.java
@@ -37,7 +37,7 @@ public class RabbitMqBasicConsumer {
         bindings = {@QueueBinding(value = @Queue(value = "topic.queue.01"),
             exchange = @Exchange(value = "topic.exchange", type = "topic"),
             key = {"*.reg.msg"})})
-    public void getTopicMessage01(String message) {
+    public void addTBasic(String message) {
         log.info("rabbitmq message:{}", message);
         basicMqCollectService.addTBasic(message);
     }
@@ -49,7 +49,7 @@ public class RabbitMqBasicConsumer {
         @QueueBinding(value = @Queue(value = "topic.queue.02"),
             exchange = @Exchange(value = "topic.exchange", type = "topic"),
             key = {"*.*.reg.msg.#"})})
-    public void getTopicMessage02(String message) {
+    public void updateTBasic(String message) {
         log.info("rabbitmq message:{}", message);
         basicMqCollectService.updateTBasic(message);
     }
diff --git a/collect-sdry/src/main/java/com/docus/server/collect/dept/mq/RabbitMqDeptConsumer.java b/collect-sdry/src/main/java/com/docus/server/collect/dept/mq/RabbitMqDeptConsumer.java
index e932b36..4c48152 100644
--- a/collect-sdry/src/main/java/com/docus/server/collect/dept/mq/RabbitMqDeptConsumer.java
+++ b/collect-sdry/src/main/java/com/docus/server/collect/dept/mq/RabbitMqDeptConsumer.java
@@ -36,7 +36,7 @@ public class RabbitMqDeptConsumer {
         bindings = {@QueueBinding(value = @Queue(value = "topic.queue.01"),
             exchange = @Exchange(value = "topic.exchange", type = "topic"),
             key = {"*.reg.msg"})})
-    public void getTopicMessage01(String message) {
+    public void addDept(String message) {
         log.info("rabbitmq message:{}", message);
         deptMqCollectService.addDept(message);
     }
@@ -48,7 +48,7 @@ public class RabbitMqDeptConsumer {
         @QueueBinding(value = @Queue(value = "topic.queue.02"),
             exchange = @Exchange(value = "topic.exchange", type = "topic"),
             key = {"*.*.reg.msg.#"})})
-    public void getTopicMessage02(String message) {
+    public void updateDept(String message) {
         log.info("rabbitmq message:{}", message);
         deptMqCollectService.updateDept(message);
     }
diff --git a/collect-sdry/src/main/java/com/docus/server/collect/user/mq/RabbitMqUserConsumer.java b/collect-sdry/src/main/java/com/docus/server/collect/user/mq/RabbitMqUserConsumer.java
index 4d54128..246f6fb 100644
--- a/collect-sdry/src/main/java/com/docus/server/collect/user/mq/RabbitMqUserConsumer.java
+++ b/collect-sdry/src/main/java/com/docus/server/collect/user/mq/RabbitMqUserConsumer.java
@@ -36,7 +36,7 @@ public class RabbitMqUserConsumer {
         bindings = {@QueueBinding(value = @Queue(value = "topic.queue.01"),
             exchange = @Exchange(value = "topic.exchange", type = "topic"),
             key = {"*.reg.msg"})})
-    public void getTopicMessage01(String message) {
+    public void addUser(String message) {
         log.info("rabbitmq message:{}", message);
         userMqCollectService.addUser(message);
     }
@@ -48,7 +48,7 @@ public class RabbitMqUserConsumer {
         @QueueBinding(value = @Queue(value = "topic.queue.02"),
             exchange = @Exchange(value = "topic.exchange", type = "topic"),
             key = {"*.*.reg.msg.#"})})
-    public void getTopicMessage02(String message) {
+    public void updateUser(String message) {
         log.info("rabbitmq message:{}", message);
         userMqCollectService.updateUser(message);
     }