jiangping
2023-10-11 8738b7aa54ebd8837e135bab88ea031b6ed788b0
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) {