diff --git a/src/main/java/org/redisson/client/handler/ConnectionWatchdog.java b/src/main/java/org/redisson/client/handler/ConnectionWatchdog.java index 99179cac3..81a030ce6 100644 --- a/src/main/java/org/redisson/client/handler/ConnectionWatchdog.java +++ b/src/main/java/org/redisson/client/handler/ConnectionWatchdog.java @@ -86,7 +86,7 @@ public class ConnectionWatchdog extends ChannelInboundHandlerAdapter { @Override public void operationComplete(final ChannelFuture future) throws Exception { - if (connection.isClosed()) { + if (connection.isClosed() || group.isShuttingDown()) { return; }