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 187abb50a..09f7d47b4 100644 --- a/redisson/src/main/java/org/redisson/client/handler/PingConnectionHandler.java +++ b/redisson/src/main/java/org/redisson/client/handler/PingConnectionHandler.java @@ -75,6 +75,13 @@ public class PingConnectionHandler extends ChannelInboundHandlerAdapter { if (connection.isClosed()) { return; } + + CommandData commandData = connection.getCurrentCommand(); + if (commandData != null && commandData.isBlockingCommand()) { + sendPing(ctx); + return; + } + if (future != null && (future.cancel(false) || !future.isSuccess())) { ctx.channel().close();