diff --git a/transport/mqtt/src/main/java/org/thingsboard/server/transport/mqtt/MqttTransportService.java b/transport/mqtt/src/main/java/org/thingsboard/server/transport/mqtt/MqttTransportService.java index f0129e1b6c..cbe3ba6a13 100644 --- a/transport/mqtt/src/main/java/org/thingsboard/server/transport/mqtt/MqttTransportService.java +++ b/transport/mqtt/src/main/java/org/thingsboard/server/transport/mqtt/MqttTransportService.java @@ -119,8 +119,8 @@ public class MqttTransportService { try { serverChannel.close().sync(); } finally { - bossGroup.shutdownGracefully(); workerGroup.shutdownGracefully(); + bossGroup.shutdownGracefully(); } log.info("MQTT transport stopped!"); }