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