From 880604da65c9b0e164399a76437721c00c1fc981 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=9D=8E=E4=B8=9C=E4=BD=B3?=
 <14614659+dongjia-li@user.noreply.gitee.com>
Date: Wed, 9 Oct 2024 22:40:12 +0800
Subject: [PATCH] =?UTF-8?q?feat():=20=E6=B7=BB=E5=8A=A0rabbitmq=E7=9B=91?=
 =?UTF-8?q?=E5=90=AC=E6=96=B9=E6=B3=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 cloud-modules/cloud-modules-protocol-parsing/pom.xml       | 5 +++++
 .../com/muyu/cloud/protocol/parsing/ParsingMessage.java    | 7 ++++++-
 2 files changed, 11 insertions(+), 1 deletion(-)

diff --git a/cloud-modules/cloud-modules-protocol-parsing/pom.xml b/cloud-modules/cloud-modules-protocol-parsing/pom.xml
index 6baf2a9..700c519 100644
--- a/cloud-modules/cloud-modules-protocol-parsing/pom.xml
+++ b/cloud-modules/cloud-modules-protocol-parsing/pom.xml
@@ -65,6 +65,11 @@
             <artifactId>cloud-common-datascope</artifactId>
         </dependency>
 
+        <dependency>
+            <groupId>com.muyu</groupId>
+            <artifactId>cloud-common-rabbit</artifactId>
+        </dependency>
+
         <!-- MuYu Common Log -->
         <dependency>
             <groupId>com.muyu</groupId>
diff --git a/cloud-modules/cloud-modules-protocol-parsing/src/main/java/com/muyu/cloud/protocol/parsing/ParsingMessage.java b/cloud-modules/cloud-modules-protocol-parsing/src/main/java/com/muyu/cloud/protocol/parsing/ParsingMessage.java
index 058c21d..a357f6b 100644
--- a/cloud-modules/cloud-modules-protocol-parsing/src/main/java/com/muyu/cloud/protocol/parsing/ParsingMessage.java
+++ b/cloud-modules/cloud-modules-protocol-parsing/src/main/java/com/muyu/cloud/protocol/parsing/ParsingMessage.java
@@ -12,6 +12,9 @@ import org.apache.kafka.clients.producer.KafkaProducer;
 import org.apache.kafka.clients.producer.ProducerRecord;
 import org.eclipse.paho.client.mqttv3.*;
 import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;
+import org.springframework.amqp.rabbit.annotation.Queue;
+import org.springframework.amqp.rabbit.annotation.RabbitListener;
+import org.springframework.amqp.rabbit.annotation.RabbitListeners;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
@@ -55,10 +58,12 @@ public class ParsingMessage {
     // kafka topic
     private static final String TIPSY = "tipsy";
 
+    private final static String FORM_QUEUE = "queue_inform_sms";
+
     /**
      * 初始化MQTT连接
      */
-    @PostConstruct
+    @RabbitListener(queuesToDeclare = @Queue(FORM_QUEUE))
     public void init() {
         connectToMqttBroker();
     }