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 4460e16b60..75ec21a8df 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 @@ -1069,7 +1069,6 @@ public class MqttTransportHandler extends ChannelInboundHandlerAdapter implement @Override public void onDeviceDeleted(DeviceId deviceId) { - doDisconnect(); context.onAuthFailure(address); ChannelHandlerContext ctx = deviceSessionCtx.getChannel(); ctx.close();