From 0bbec75e7550eb427f9f62b67d2001cec14cd8c4 Mon Sep 17 00:00:00 2001
From: Artem Barysh <abarysh@thingsboard.io>
Date: Wed, 28 May 2025 18:16:54 +0300
Subject: [PATCH] Fixed channel disconnection

---
 .../src/main/java/org/thingsboard/mqtt/MqttClientImpl.java      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/netty-mqtt/src/main/java/org/thingsboard/mqtt/MqttClientImpl.java b/netty-mqtt/src/main/java/org/thingsboard/mqtt/MqttClientImpl.java
index 543553951d..65c195ea03 100644
--- a/netty-mqtt/src/main/java/org/thingsboard/mqtt/MqttClientImpl.java
+++ b/netty-mqtt/src/main/java/org/thingsboard/mqtt/MqttClientImpl.java
@@ -462,7 +462,7 @@ final class MqttClientImpl implements MqttClient {
             MqttMessage message = new MqttMessage(new MqttFixedHeader(MqttMessageType.DISCONNECT, false, MqttQoS.AT_MOST_ONCE, false, 0));
             ChannelFuture channelFuture = this.sendAndFlushPacket(message);
             eventLoop.schedule(() -> {
-                if (!channelFuture.isDone()) {
+                if (channel.isOpen()) {
                     this.channel.close();
                 }
             }, 500, TimeUnit.MILLISECONDS);