From cde49794973557adda93091606a9820e7fddb46f Mon Sep 17 00:00:00 2001 From: jiangping <jp@doumee.com> Date: 星期三, 11 十月 2023 17:03:58 +0800 Subject: [PATCH] Merge branch 'dev' of http://139.186.142.91:10010/r/productDev/parkBike into dev --- server/services/src/main/java/com/doumee/core/mqtt/service/MqttPushCallback.java | 5 ++++- 1 files changed, 4 insertions(+), 1 deletions(-) diff --git a/server/services/src/main/java/com/doumee/core/mqtt/service/MqttPushCallback.java b/server/services/src/main/java/com/doumee/core/mqtt/service/MqttPushCallback.java index aee7901..e49e693 100644 --- a/server/services/src/main/java/com/doumee/core/mqtt/service/MqttPushCallback.java +++ b/server/services/src/main/java/com/doumee/core/mqtt/service/MqttPushCallback.java @@ -1,5 +1,6 @@ package com.doumee.core.mqtt.service; +import com.doumee.core.mqtt.config.MqttConfig; import com.doumee.service.business.DeviceService; import com.doumee.service.business.DeviceSubcribeService; import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken; @@ -15,12 +16,14 @@ public class MqttPushCallback implements MqttCallback { @Autowired private DeviceSubcribeService deviceSubcribeService; + @Autowired + private MqttConfig mqttConfig; //鎺ユ敹娑堟伅鍥炶皟 @Override public void connectionLost(Throwable cause) { // 杩炴帴涓㈠け鍚庯紝涓�鑸湪杩欓噷闈㈣繘琛岄噸杩� - System.out.println("杩炴帴鏂紑锛屽彲浠ュ仛閲嶈繛"); +// System.out.println("杩炴帴鏂紑锛屽彲浠ュ仛閲嶈繛"); } @Override -- Gitblit v1.9.3