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 39f6e7773..2999e25c6 100644 --- a/redisson/src/main/java/org/redisson/client/handler/PingConnectionHandler.java +++ b/redisson/src/main/java/org/redisson/client/handler/PingConnectionHandler.java @@ -72,6 +72,9 @@ public class PingConnectionHandler extends ChannelInboundHandlerAdapter { config.getTimer().newTimeout(new TimerTask() { @Override public void run(Timeout timeout) throws Exception { + if (connection.isClosed()) { + return; + } if (future != null && (future.cancel(false) || !future.isSuccess())) { ctx.channel().close();