diff --git a/redisson/src/main/java/org/redisson/client/handler/ConnectionWatchdog.java b/redisson/src/main/java/org/redisson/client/handler/ConnectionWatchdog.java index d9bb84fca..dbe42272d 100644 --- a/redisson/src/main/java/org/redisson/client/handler/ConnectionWatchdog.java +++ b/redisson/src/main/java/org/redisson/client/handler/ConnectionWatchdog.java @@ -152,12 +152,6 @@ public class ConnectionWatchdog extends ChannelInboundHandlerAdapter { } } - @Override - public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception { - ctx.channel().close(); - super.exceptionCaught(ctx, cause); - } - private void refresh(RedisConnection connection, Channel channel) { CommandData<?, ?> commandData = connection.getCurrentCommand(); connection.updateChannel(channel);