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;
