zcy
/
iotkit-parent
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

update: nb组件产品上 qos=0

V0.5.x
jay 2023-08-09 10:20:23 +08:00
parent d5d1bf966f
commit 0e1dd0ebad
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
iot-components/iot-nb-component/src/main/java/cc/iotkit/comp/nb/NBVerticle.java
View File

@ -215,7 +215,7 @@ public class NBVerticle extends AbstractVerticle {
throw new BizException(ErrCode.SEND_DESTINATION_NOT_FOUND);
}
Future<Integer> result = endpoint.publish(topic, msg,
MqttQoS.AT_LEAST_ONCE, false, false);
MqttQoS.AT_MOST_ONCE, false, false);
result.onFailure(e -> log.error("public topic failed", e));
result.onSuccess(integer -> log.info("publish success,topic:{},payload:{}", topic, msg));
}