Skip to content

Commit

Permalink
Fixed - PingConnectionHandler should close channel on RedisLoadingExc…
Browse files Browse the repository at this point in the history
…eption, RedisTryAgainException, RedisClusterDownException, RedisBusyException #4440
  • Loading branch information
Nikita Koksharov committed Aug 23, 2022
1 parent 22dccb7 commit 7aa2775
Showing 1 changed file with 1 addition and 1 deletion.
Expand Up @@ -87,6 +87,7 @@ private void sendPing(ChannelHandlerContext ctx) {
|| cause instanceof RedisTryAgainException
|| cause instanceof RedisClusterDownException
|| cause instanceof RedisBusyException)) {
log.debug("channel: {} closed due to PING response timeout set in {} ms", ctx.channel(), config.getPingConnectionInterval());
ctx.channel().close();
} else {
sendPing(ctx);
Expand All @@ -95,7 +96,6 @@ private void sendPing(ChannelHandlerContext ctx) {
if (cause != null && !future.isCancelled()) {
log.error("Unable to send PING command over channel: " + ctx.channel(), cause);
}
log.debug("channel: {} closed due to PING response timeout set in {} ms", ctx.channel(), config.getPingConnectionInterval());
} else {
sendPing(ctx);
}
Expand Down

0 comments on commit 7aa2775

Please sign in to comment.