分支自 ard/ruoyi-api
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
zhangnaisong
2024-07-22 c3ec70d2bd1ebd2421d2fa3e85c1ac43e2322ea6 
 ard-work/src/main/java/com/ruoyi/utils/mqtt/MqttConsumer.java


@@ -6,6 +6,7 @@


import org.springframework.beans.factory.annotation.Value;


import org.springframework.boot.ApplicationArguments;


import org.springframework.boot.ApplicationRunner;


import org.springframework.core.annotation.Order;


import org.springframework.stereotype.Component;


import java.io.UnsupportedEncodingException;


/**


@@ -17,6 +18,7 @@


 **/


@Component


@Slf4j(topic = "mqtt")


@Order(1)


public class MqttConsumer implements ApplicationRunner {




    @Value("${mqtt.enabled}")