From 0e1dd0ebad885455cc86dedb650034d7cebb7c2a Mon Sep 17 00:00:00 2001 From: jay <75509151@qq.com> Date: Wed, 9 Aug 2023 10:20:23 +0800 Subject: [PATCH] =?UTF-8?q?update:=20nb=E7=BB=84=E4=BB=B6=E4=BA=A7?= =?UTF-8?q?=E5=93=81=E4=B8=8A=20qos=3D0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/main/java/cc/iotkit/comp/nb/NBVerticle.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/iot-components/iot-nb-component/src/main/java/cc/iotkit/comp/nb/NBVerticle.java b/iot-components/iot-nb-component/src/main/java/cc/iotkit/comp/nb/NBVerticle.java index f3523f42..6f025c31 100644 --- a/iot-components/iot-nb-component/src/main/java/cc/iotkit/comp/nb/NBVerticle.java +++ b/iot-components/iot-nb-component/src/main/java/cc/iotkit/comp/nb/NBVerticle.java @@ -215,7 +215,7 @@ public class NBVerticle extends AbstractVerticle { throw new BizException(ErrCode.SEND_DESTINATION_NOT_FOUND); } Future 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)); }