diff --git a/redisson/src/main/java/org/redisson/connection/SentinelConnectionManager.java b/redisson/src/main/java/org/redisson/connection/SentinelConnectionManager.java index 834f84ee3..f37c8b867 100755 --- a/redisson/src/main/java/org/redisson/connection/SentinelConnectionManager.java +++ b/redisson/src/main/java/org/redisson/connection/SentinelConnectionManager.java @@ -274,7 +274,7 @@ public class SentinelConnectionManager extends MasterSlaveConnectionManager { private void scheduleSentinelDNSCheck() { monitorFuture = serviceManager.newTimeout(t -> { CompletableFuture f = performSentinelDNSCheck(); - f.thenAccept(r -> scheduleSentinelDNSCheck()); + f.whenComplete((r, e) -> scheduleSentinelDNSCheck()); }, config.getDnsMonitoringInterval(), TimeUnit.MILLISECONDS); } @@ -328,7 +328,7 @@ public class SentinelConnectionManager extends MasterSlaveConnectionManager { } disconnectedSentinels.clear(); CompletableFuture f = performSentinelDNSCheck(); - f.thenAccept(r -> scheduleChangeCheck(cfg, null)); + f.whenComplete((r, e) -> scheduleChangeCheck(cfg, null)); return; } if (serviceManager.isShuttingDown()) {