diff --git a/src/main/java/org/redisson/connection/SentinelConnectionManager.java b/src/main/java/org/redisson/connection/SentinelConnectionManager.java index c9d11e1f8..dcba0276a 100755 --- a/src/main/java/org/redisson/connection/SentinelConnectionManager.java +++ b/src/main/java/org/redisson/connection/SentinelConnectionManager.java @@ -30,7 +30,6 @@ import org.redisson.client.RedisClient; import org.redisson.client.RedisConnection; import org.redisson.client.RedisConnectionException; import org.redisson.client.RedisPubSubConnection; -import org.redisson.client.codec.Codec; import org.redisson.client.codec.StringCodec; import org.redisson.client.protocol.RedisCommands; import org.redisson.client.protocol.pubsub.PubSubType; @@ -95,15 +94,14 @@ public class SentinelConnectionManager extends MasterSlaveConnectionManager { String port = map.get("port"); String flags = map.get("flags"); - String host = ip + ":" + port; + String host = ip + ":" + port; - c.addSlaveAddress(host); - slaves.put(host, true); - log.info("slave: {} added, params: {}", host, map); + c.addSlaveAddress(host); + slaves.put(host, true); + log.info("slave: {} added, params: {}", host, map); - if (flags.contains("s_down") || flags.contains("disconnected")) { - disconnectedSlaves.add(host); - } + if (flags.contains("s_down") || flags.contains("disconnected")) { + disconnectedSlaves.add(host); } } break;