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