diff --git a/redisson/src/main/java/org/redisson/connection/MasterSlaveConnectionManager.java b/redisson/src/main/java/org/redisson/connection/MasterSlaveConnectionManager.java index 1558bc4b4..dd6003674 100644 --- a/redisson/src/main/java/org/redisson/connection/MasterSlaveConnectionManager.java +++ b/redisson/src/main/java/org/redisson/connection/MasterSlaveConnectionManager.java @@ -354,24 +354,21 @@ public class MasterSlaveConnectionManager implements ConnectionManager { protected void initSingleEntry() { try { - MasterSlaveEntry entry; if (config.checkSkipSlavesInit()) { - entry = new SingleEntry(this, config); + masterSlaveEntry = new SingleEntry(this, config); } else { - entry = new MasterSlaveEntry(this, config); + masterSlaveEntry = new MasterSlaveEntry(this, config); } - RFuture masterFuture = entry.setupMasterEntry(new RedisURI(config.getMasterAddress())); + RFuture masterFuture = masterSlaveEntry.setupMasterEntry(new RedisURI(config.getMasterAddress())); masterFuture.syncUninterruptibly(); if (!config.checkSkipSlavesInit()) { - List> fs = entry.initSlaveBalancer(getDisconnectedNodes(), masterFuture.getNow()); + List> fs = masterSlaveEntry.initSlaveBalancer(getDisconnectedNodes(), masterFuture.getNow()); for (RFuture future : fs) { future.syncUninterruptibly(); } } - masterSlaveEntry = entry; - startDNSMonitoring(masterFuture.getNow()); } catch (Exception e) { stopThreads();