From 1631a7cae8eeadb22097f00dd213a693cd5d021b Mon Sep 17 00:00:00 2001
From: LQS <2506203757@qq.com>
Date: Sat, 12 Oct 2024 11:09:14 +0800
Subject: [PATCH] =?UTF-8?q?feat():=E4=BF=AE=E5=A4=8DMQTT=E8=BF=9E=E6=8E=A5?=
 =?UTF-8?q?=EF=BC=8C=E6=8E=A5=E6=94=B6rabbitMq=E6=95=B0=E6=8D=AE=E6=B6=88?=
 =?UTF-8?q?=E8=B4=B9=EF=BC=8C=E6=8B=BF=E5=88=B0=E6=95=B0=E6=8D=AE=E8=A7=A3?=
 =?UTF-8?q?=E6=9E=90=E6=8A=95=E9=80=92kafka?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../analysis/parsing/MQTT/service/MqttClientService.java  | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/cloud-modules/cloud-modules-protocol-analysis/src/main/java/com/muyu/analysis/parsing/MQTT/service/MqttClientService.java b/cloud-modules/cloud-modules-protocol-analysis/src/main/java/com/muyu/analysis/parsing/MQTT/service/MqttClientService.java
index 02e1396..2113df5 100644
--- a/cloud-modules/cloud-modules-protocol-analysis/src/main/java/com/muyu/analysis/parsing/MQTT/service/MqttClientService.java
+++ b/cloud-modules/cloud-modules-protocol-analysis/src/main/java/com/muyu/analysis/parsing/MQTT/service/MqttClientService.java
@@ -53,10 +53,10 @@ public class MqttClientService {
     }
 
     private void connectAndSubscribe(MqttProperties mqttProperties) throws MqttException, IOException {
-//        if (sampleClient != null && sampleClient.isConnected()) {
-//            log.info("MQTT客户端已经连接，跳过重新连接。");
-//            return;
-//        }
+        if (sampleClient != null && sampleClient.isConnected()) {
+            log.info("MQTT客户端已经连接，跳过重新连接。");
+            return;
+        }
 
         sampleClient = new MqttClient(mqttProperties.getBroker(), mqttProperties.getClientId());
         MqttConnectOptions connOpts = new MqttConnectOptions();