diff --git a/broker/src/main/java/io/moquette/server/ConnectionDescriptor.java b/broker/src/main/java/io/moquette/server/ConnectionDescriptor.java index 67082fb2..9ea41bcf 100644 --- a/broker/src/main/java/io/moquette/server/ConnectionDescriptor.java +++ b/broker/src/main/java/io/moquette/server/ConnectionDescriptor.java @@ -103,7 +103,7 @@ public class ConnectionDescriptor { LOG.info("Closing connection descriptor. MqttClientId = {}.", clientID); // try { // this.channel.disconnect().sync(); - this.channel.close();// .sync(); + this.channel.close(); // .sync(); // } catch (InterruptedException e) { // e.printStackTrace(); // } @@ -145,7 +145,6 @@ public class ConnectionDescriptor { if (clientID != null ? !clientID.equals(that.clientID) : that.clientID != null) return false; return !(channel != null ? !channel.equals(that.channel) : that.channel != null); - } public BytesMetrics getBytesMetrics() {