diff --git a/.idea/misc.xml b/.idea/misc.xml index 9533805..90fdf05 100644 --- a/.idea/misc.xml +++ b/.idea/misc.xml @@ -8,5 +8,5 @@ - + \ No newline at end of file diff --git a/ems-framework/src/main/java/com/xzzn/framework/manager/MqttLifecycleManager.java b/ems-framework/src/main/java/com/xzzn/framework/manager/MqttLifecycleManager.java index 234382a..5c25a81 100644 --- a/ems-framework/src/main/java/com/xzzn/framework/manager/MqttLifecycleManager.java +++ b/ems-framework/src/main/java/com/xzzn/framework/manager/MqttLifecycleManager.java @@ -17,7 +17,7 @@ public class MqttLifecycleManager implements ApplicationRunner, SmartLifecycle, private final MqttConnectOptions connectOptions; private MqttClient mqttClient; - private volatile boolean running = false; + private volatile boolean running = true; // 存储订阅关系: topic -> (listener, qos) private final ConcurrentHashMap subscriptions = new ConcurrentHashMap<>();