server/services/src/main/java/com/doumee/core/mqtt/service/MqttToolService.java | ●●●●● 补丁 | 查看 | 原始文档 | 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()); }