From 811b14aa5cd2bd6d4313b43dc38ce87cd938f3b0 Mon Sep 17 00:00:00 2001 From: liusuyi <1951119284@qq.com> Date: 星期二, 23 七月 2024 17:12:42 +0800 Subject: [PATCH] 优化:通道同步任务 增加:根据用户统计未读总数 --- ard-work/src/main/java/com/ruoyi/utils/qymqtt/newM/EmqClient.java | 2 ++ 1 files changed, 2 insertions(+), 0 deletions(-) diff --git a/ard-work/src/main/java/com/ruoyi/utils/qymqtt/newM/EmqClient.java b/ard-work/src/main/java/com/ruoyi/utils/qymqtt/newM/EmqClient.java index 2c0d40c..9c8c409 100644 --- a/ard-work/src/main/java/com/ruoyi/utils/qymqtt/newM/EmqClient.java +++ b/ard-work/src/main/java/com/ruoyi/utils/qymqtt/newM/EmqClient.java @@ -4,6 +4,7 @@ import com.ruoyi.common.utils.spring.SpringUtils; import com.ruoyi.sy.service.ArdSyCarRtuService; +import lombok.extern.slf4j.Slf4j; import org.eclipse.paho.client.mqttv3.IMqttClient; import org.eclipse.paho.client.mqttv3.MqttClient; import org.eclipse.paho.client.mqttv3.MqttClientPersistence; @@ -12,6 +13,7 @@ import org.eclipse.paho.client.mqttv3.MqttMessage; import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence; +@Slf4j(topic = "mqttCar") public class EmqClient { private IMqttClient mqttClient; -- Gitblit v1.9.3