aa
jiangping
2023-10-13 2fa5623c67ccb6934c13844356590a76c24ac7b6
aa
已修改1个文件
5 ■■■■■ 文件已修改
server/services/src/main/java/com/doumee/core/mqtt/service/MqttToolService.java 5 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
server/services/src/main/java/com/doumee/core/mqtt/service/MqttToolService.java
@@ -42,13 +42,8 @@
        mess.setRetained(true);
        mess.setPayload(message.getBytes());
        try {
<<<<<<< HEAD
            MqttClientInit.getInstance(config).publish(topic, mess);
            return  1;
=======
            MqttClientInit.getInstance(config,callBack).publish(topic, mess);
            return  0;
>>>>>>> 07088f4225d6c8d21e94cc4981d4c28960f114d8
        } catch (Exception e) {
            //LOGGER.error(e.getLocalizedMessage());
        }