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); } }