root
/
agri
2
0
Fork 0
Code Issues Pull Requests Packages Projects 1 Releases Wiki Activity

去掉无用日志

feasure
xce 2026-01-16 18:23:58 +08:00
parent 6fd96b188c
commit bc24edef61
1 changed files with 0 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
agri-framework/src/main/java/com/agri/framework/interceptor/MqttMessageHandler.java
View File

@ -575,11 +575,9 @@ public class MqttMessageHandler implements SmartLifecycle {
public void start() { public void start() {
log.info("开始监听"); log.info("开始监听");
if (isRunning.compareAndSet(false, true)) { if (isRunning.compareAndSet(false, true)) {
log.info("开始监听111");
try { try {
// 核心修改：无论是否已连接，都执行订阅（设置回调+订阅主题） // 核心修改：无论是否已连接，都执行订阅（设置回调+订阅主题）
// 移除原有的if (!mqttClient.isConnected()) 判断 // 移除原有的if (!mqttClient.isConnected()) 判断
log.info("开始监听222");
subscribeTopics(); subscribeTopics();
log.info("【MQTT生命周期】客户端启动成功（已设置回调+订阅主题）"); log.info("【MQTT生命周期】客户端启动成功（已设置回调+订阅主题）");
} catch (MqttException e) { } catch (MqttException e) {