xzzn/emsback
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Compare commits

base: xzzn:619c05e965c7d071eaaa956b86f34357f5e6724d
Branches Tags
xzzn:main xzzn:dev xzzn:waibao xzzn:prod
...
compare: xzzn:prod
Branches Tags
xzzn:dev xzzn:waibao xzzn:main xzzn:prod

2 Commits
619c05e965 ... prod

Author SHA1 Message Date
mashili
44baca6c45 revert 2025-08-06 22:26:04 +08:00
mashili
f59eeab0d0 本地ems不订阅mqtt 2025-08-06 22:23:48 +08:00
1 changed files with 1 additions and 1 deletions
Expand all files Collapse all files

2
ems-framework/src/main/java/com/xzzn/framework/manager/MqttLifecycleManager.java
View File

@ -17,7 +17,7 @@ public class MqttLifecycleManager implements ApplicationRunner, SmartLifecycle,
private final MqttConnectOptions connectOptions; private final MqttConnectOptions connectOptions;
private MqttClient mqttClient; private MqttClient mqttClient;
private volatile boolean running = false; private volatile boolean running = true;
// 存储订阅关系: topic -> (listener, qos) // 存储订阅关系: topic -> (listener, qos)
private final ConcurrentHashMap<String, SubscriptionInfo> subscriptions = new ConcurrentHashMap<>(); private final ConcurrentHashMap<String, SubscriptionInfo> subscriptions = new ConcurrentHashMap<>();