From 6d32e3f712fe7b7c615129c8ff8a888454c35a34 Mon Sep 17 00:00:00 2001
From: zbeacon <ibarkov.ua@gmail.com>
Date: Mon, 24 Jan 2022 13:16:49 +0200
Subject: [PATCH] Moved sending response to onDeviceDeleted method

---
 .../server/transport/mqtt/MqttTransportHandler.java         | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/common/transport/mqtt/src/main/java/org/thingsboard/server/transport/mqtt/MqttTransportHandler.java b/common/transport/mqtt/src/main/java/org/thingsboard/server/transport/mqtt/MqttTransportHandler.java
index 2f52923e63..4460e16b60 100644
--- a/common/transport/mqtt/src/main/java/org/thingsboard/server/transport/mqtt/MqttTransportHandler.java
+++ b/common/transport/mqtt/src/main/java/org/thingsboard/server/transport/mqtt/MqttTransportHandler.java
@@ -929,9 +929,6 @@ public class MqttTransportHandler extends ChannelInboundHandlerAdapter implement
                 gatewaySessionHandler.onGatewayDisconnect();
             }
             deviceSessionCtx.setDisconnected();
-            context.onAuthFailure(address);
-            ChannelHandlerContext ctx = deviceSessionCtx.getChannel();
-            ctx.close();
         }
         deviceSessionCtx.release();
     }
@@ -1073,6 +1070,9 @@ public class MqttTransportHandler extends ChannelInboundHandlerAdapter implement
     @Override
     public void onDeviceDeleted(DeviceId deviceId) {
         doDisconnect();
+        context.onAuthFailure(address);
+        ChannelHandlerContext ctx = deviceSessionCtx.getChannel();
+        ctx.close();
     }
 
 }