github-forks
/
redisson
mirror of https://github.com/redisson/redisson.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

compilation fixed

Browse Source
pull/382/head
Nikita 9 years ago
parent 10e382eb1f
commit ef10f0fecb
1 changed files with 6 additions and 8 deletions
Show Stats Download Patch File Download Diff File

14
src/main/java/org/redisson/connection/SentinelConnectionManager.java
Unescape Escape View File

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

Write Preview
Loading…
Cancel
Save