From 0e52779267ece968b19237d20fc11f186b2d34ce Mon Sep 17 00:00:00 2001 From: huangfeng Date: Mon, 9 Jun 2025 10:18:15 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E5=8F=96=E6=B6=88=E8=AE=A2=E9=98=85?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../shxy/xymanager_service/mqtt/MqttSubscriberService.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/xymanager_service/src/main/java/com/shxy/xymanager_service/mqtt/MqttSubscriberService.java b/xymanager_service/src/main/java/com/shxy/xymanager_service/mqtt/MqttSubscriberService.java index 35165d6..c4cf2b4 100644 --- a/xymanager_service/src/main/java/com/shxy/xymanager_service/mqtt/MqttSubscriberService.java +++ b/xymanager_service/src/main/java/com/shxy/xymanager_service/mqtt/MqttSubscriberService.java @@ -66,7 +66,9 @@ public class MqttSubscriberService { @PreDestroy private void preDestroy() { try { - mqttClient.unsubscribe(topicList.toArray(new String[0])); + if (topicList.size() > 0) { + mqttClient.unsubscribe(topicList.toArray(new String[0])); + } if (mqttClient.isConnected()) { mqttClient.disconnect(); }