被动rabbitmq模板封装

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);
     }

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);
     }

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);
     }