From e7bdea6cd476f3adb2f75db07136690c72fb93a3 Mon Sep 17 00:00:00 2001 From: Nikita Koksharov Date: Tue, 30 Jan 2024 13:53:11 +0300 Subject: [PATCH] Fixed - connection ping handler doesn't use commandTimeout. #5493 --- .../org/redisson/client/handler/PingConnectionHandler.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/redisson/src/main/java/org/redisson/client/handler/PingConnectionHandler.java b/redisson/src/main/java/org/redisson/client/handler/PingConnectionHandler.java index 22c3b0c0c..c6099ec27 100644 --- a/redisson/src/main/java/org/redisson/client/handler/PingConnectionHandler.java +++ b/redisson/src/main/java/org/redisson/client/handler/PingConnectionHandler.java @@ -62,7 +62,8 @@ public class PingConnectionHandler extends ChannelInboundHandlerAdapter { RFuture future; CommandData currentCommand = connection.getCurrentCommand(); if (connection.getUsage() == 0 && (currentCommand == null || !currentCommand.isBlockingCommand())) { - future = connection.async(config.getPingConnectionInterval() / 2, StringCodec.INSTANCE, RedisCommands.PING); + int timeout = Math.max(config.getCommandTimeout(), config.getPingConnectionInterval() / 2); + future = connection.async(timeout, StringCodec.INSTANCE, RedisCommands.PING); } else { future = null; }