update RedisClientHub

netease-im · Jun 25, 2021 · 8507f78 · 8507f78
1 parent 1d179c9
commit 8507f78
Showing 1 changed file with 10 additions and 6 deletions.
diff --git a/...roxy/src/main/java/com/netease/nim/camellia/redis/proxy/command/async/RedisClientHub.java b/...roxy/src/main/java/com/netease/nim/camellia/redis/proxy/command/async/RedisClientHub.java
@@ -362,12 +362,16 @@ public Boolean call() {
                             redisClient.getClientName(), delaySeconds);
                     redisClient.markClosing();
                     ExecutorUtils.newTimeout(timeout -> {
-                        //double check
-                        if (redisClient.isIdle()) {
-                            logger.info("{} will close because connection is idle", redisClient.getClientName());
-                            redisClient.stop(true);
-                        } else {
-                            checkIdleAndStop(redisClient);
+                        try {
+                            //double check
+                            if (redisClient.isIdle()) {
+                                logger.info("{} will close because connection is idle", redisClient.getClientName());
+                                redisClient.stop(true);
+                            } else {
+                                checkIdleAndStop(redisClient);
+                            }
+                        } catch (Exception e) {
+                            logger.error(e.getMessage(), e);
                         }
                     }, delaySeconds, TimeUnit.SECONDS);
                     return true;