瀏覽代碼

fix mqtt connection

tags/v0.8.5^2
yk 2 年之前
父節點
當前提交
ff0b6ade4e
共有 1 個檔案被更改,包括 1 行新增1 行删除
  1. +1
    -1
      xueyi-modules/xueyi-message/src/main/java/com/xueyi/message/handler/MqttTopicHandle.java

+ 1
- 1
xueyi-modules/xueyi-message/src/main/java/com/xueyi/message/handler/MqttTopicHandle.java 查看文件

@@ -43,7 +43,7 @@ public class MqttTopicHandle {
System.err.println("rev heartbeat mqtt msg:"+message.getPayload().toString());
}

@MqttTopic("/digital_man/heart_beat")
@MqttTopic("/digital_man/log_upload_notification")
public void logUpload(Message message){
//TODO. 预警上报 mqtt 处理逻辑
System.err.println("rev logUpload mqtt msg:"+message.getPayload().toString());


Loading…
取消
儲存