Fixed - closed channel detection by PingConnectionHandler #6079

pull/1461/merge
mrniko 1 month ago
parent a98540af0b
commit 0bda4b5b44

@ -110,6 +110,7 @@ public class PingConnectionHandler extends ChannelInboundHandlerAdapter {
private static boolean isClosed(ChannelHandlerContext ctx, RedisConnection connection) { private static boolean isClosed(ChannelHandlerContext ctx, RedisConnection connection) {
return connection.isClosed() return connection.isClosed()
|| !ctx.channel().equals(connection.getChannel())
|| ctx.isRemoved() || ctx.isRemoved()
|| connection.getRedisClient().isShutdown(); || connection.getRedisClient().isShutdown();
} }

Loading…
Cancel
Save