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,6 +16,8 @@ public class MqttPushCallback implements MqttCallback { @Autowired private DeviceSubcribeService deviceSubcribeService; @Autowired private MqttConfig mqttConfig; //接收消息回调 @Override public void connectionLost(Throwable cause) {