From 89dd6344ec16403bcf69034ca02eff011c6273fb Mon Sep 17 00:00:00 2001 From: Nikita Koksharov Date: Mon, 1 Mar 2021 08:51:53 +0300 Subject: [PATCH] refactoring --- .../connection/SentinelConnectionManager.java | 13 ++++--------- 1 file changed, 4 insertions(+), 9 deletions(-) diff --git a/redisson/src/main/java/org/redisson/connection/SentinelConnectionManager.java b/redisson/src/main/java/org/redisson/connection/SentinelConnectionManager.java index 4700bfb10..2c6ffc4c4 100755 --- a/redisson/src/main/java/org/redisson/connection/SentinelConnectionManager.java +++ b/redisson/src/main/java/org/redisson/connection/SentinelConnectionManager.java @@ -270,16 +270,11 @@ public class SentinelConnectionManager extends MasterSlaveConnectionManager { @Override public void run() { AtomicInteger sentinelsCounter = new AtomicInteger(sentinelHosts.size()); - FutureListener> commonListener = new FutureListener>() { - @Override - public void operationComplete(Future> future) throws Exception { - if (sentinelsCounter.decrementAndGet() == 0) { - scheduleSentinelDNSCheck(); - } + performSentinelDNSCheck(future -> { + if (sentinelsCounter.decrementAndGet() == 0) { + scheduleSentinelDNSCheck(); } - }; - - performSentinelDNSCheck(commonListener); + }); } }, config.getDnsMonitoringInterval(), TimeUnit.MILLISECONDS); }