From 710ee6c293c1a89ccc29120b4443cb74bee39b9e Mon Sep 17 00:00:00 2001 From: jay <75509151@qq.com> Date: Tue, 5 Sep 2023 11:35:10 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E8=AE=BE=E5=A4=87=E8=A7=A6=E5=8F=91clos?= =?UTF-8?q?ehandler=E5=90=8E,=E4=BB=8D=E7=84=B6=E8=83=BD=E4=B8=8A=E6=8A=A5?= =?UTF-8?q?=E6=B6=88=E6=81=AF,=E8=AE=BE=E5=A4=87=E7=8A=B6=E6=80=81?= =?UTF-8?q?=E4=B8=8D=E6=AD=A3=E7=A1=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/main/java/cc/iotkit/comp/nb/NBVerticle.java | 1 + 1 file changed, 1 insertion(+) 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 6f025c31..c8e31109 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 @@ -114,6 +114,7 @@ public class NBVerticle extends AbstractVerticle { //删除设备与连接关系 endpointMap.remove(getEndpointKey(r)); }); + endpoint.close(); }).disconnectMessageHandler(disconnectMessage -> { log.info("Received disconnect from client, reason code = {}", disconnectMessage.code()); executor.onReceive(new HashMap<>(), "disconnect", clientId, (r) -> {