diff --git a/src/main/java/org/redisson/cluster/ClusterConnectionManager.java b/src/main/java/org/redisson/cluster/ClusterConnectionManager.java index 229b0067d..e00637f12 100644 --- a/src/main/java/org/redisson/cluster/ClusterConnectionManager.java +++ b/src/main/java/org/redisson/cluster/ClusterConnectionManager.java @@ -303,11 +303,11 @@ public class ClusterConnectionManager extends MasterSlaveConnectionManager { private void checkSlaveNodesChange(Collection newPartitions) { for (ClusterPartition newPart : newPartitions) { - for (ClusterPartition currentPart : lastPartitions.values()) { + for (final ClusterPartition currentPart : lastPartitions.values()) { if (!newPart.getMasterAddress().equals(currentPart.getMasterAddress())) { continue; } - MasterSlaveEntry entry = getEntry(currentPart.getMasterAddr()); + final MasterSlaveEntry entry = getEntry(currentPart.getMasterAddr()); Set removedSlaves = new HashSet(currentPart.getSlaveAddresses()); removedSlaves.removeAll(newPart.getSlaveAddresses()); @@ -321,7 +321,7 @@ public class ClusterConnectionManager extends MasterSlaveConnectionManager { Set addedSlaves = new HashSet(newPart.getSlaveAddresses()); addedSlaves.removeAll(currentPart.getSlaveAddresses()); - for (URI uri : addedSlaves) { + for (final URI uri : addedSlaves) { Future future = entry.addSlave(uri.getHost(), uri.getPort()); future.addListener(new FutureListener() { @Override diff --git a/src/main/java/org/redisson/connection/SentinelConnectionManager.java b/src/main/java/org/redisson/connection/SentinelConnectionManager.java index 4f43d48f2..ab1dcd76e 100755 --- a/src/main/java/org/redisson/connection/SentinelConnectionManager.java +++ b/src/main/java/org/redisson/connection/SentinelConnectionManager.java @@ -203,7 +203,7 @@ public class SentinelConnectionManager extends MasterSlaveConnectionManager { String ip = parts[2]; String port = parts[3]; - String slaveAddr = ip + ":" + port; + final String slaveAddr = ip + ":" + port; // to avoid addition twice if (slaves.putIfAbsent(slaveAddr, true) == null && config.getReadMode() == ReadMode.SLAVE) {