From 2c43c74fe3bdcf5fcf646dc2e7d612f7125baca6 Mon Sep 17 00:00:00 2001 From: andsel Date: Wed, 4 Jan 2017 11:13:58 +0100 Subject: [PATCH] Added gracefull handling when client cut TCP connection --- .../main/java/io/moquette/server/netty/NettyMQTTHandler.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/broker/src/main/java/io/moquette/server/netty/NettyMQTTHandler.java b/broker/src/main/java/io/moquette/server/netty/NettyMQTTHandler.java index 5495d08e..a33e4017 100644 --- a/broker/src/main/java/io/moquette/server/netty/NettyMQTTHandler.java +++ b/broker/src/main/java/io/moquette/server/netty/NettyMQTTHandler.java @@ -28,6 +28,8 @@ import io.netty.handler.codec.CorruptedFrameException; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +import java.io.IOException; + /** * * @author andrea @@ -100,6 +102,8 @@ public class NettyMQTTHandler extends ChannelInboundHandlerAdapter { if (cause instanceof CorruptedFrameException) { //something goes bad with decoding LOG.warn("Error decoding a packet, probably a bad formatted packet, message: " + cause.getMessage()); + } else if (cause instanceof IOException && "Connection reset by peer".equals(cause.getMessage())) { + LOG.warn("Network connection closed abruptly"); } else { LOG.error("Ugly error on networking", cause); }