From b171ad46ab370ae399804b29a2467172f70ad383 Mon Sep 17 00:00:00 2001 From: Silvio Giebl Date: Fri, 21 Feb 2020 21:06:49 +0100 Subject: [PATCH] Do not log IOExceptions while disconnecting --- .../mqtt/handler/disconnect/MqttDisconnectHandler.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/hivemq/client/internal/mqtt/handler/disconnect/MqttDisconnectHandler.java b/src/main/java/com/hivemq/client/internal/mqtt/handler/disconnect/MqttDisconnectHandler.java index 2cebcdf9d..c45dddd02 100644 --- a/src/main/java/com/hivemq/client/internal/mqtt/handler/disconnect/MqttDisconnectHandler.java +++ b/src/main/java/com/hivemq/client/internal/mqtt/handler/disconnect/MqttDisconnectHandler.java @@ -45,6 +45,7 @@ import org.jetbrains.annotations.Nullable; import javax.inject.Inject; +import java.io.IOException; import java.util.concurrent.TimeUnit; import static com.hivemq.client.internal.mqtt.handler.disconnect.MqttDisconnectUtil.fireDisconnectEvent; @@ -113,8 +114,8 @@ public void exceptionCaught(final @NotNull ChannelHandlerContext ctx, final @Not if (state == null) { state = State.CLOSED; fireDisconnectEvent(ctx.channel(), new ConnectionClosedException(cause), MqttDisconnectSource.CLIENT); - } else { - LOGGER.error("Exception while disconnecting.", cause); + } else if (!(cause instanceof IOException)) { + LOGGER.warn("Exception while disconnecting: {}", cause); } }