Fixed - NullPointerException is thrown if Redis node doesn't return "flags" parameter #3308

pull/3332/head^2
Nikita Koksharov 4 years ago
parent 129806db8e
commit fd07204e88

@ -131,7 +131,7 @@ public class SentinelConnectionManager extends MasterSlaveConnectionManager {
String ip = map.get("ip"); String ip = map.get("ip");
String port = map.get("port"); String port = map.get("port");
String flags = map.get("flags"); String flags = map.getOrDefault("flags", "");
RedisURI host = toURI(ip, port); RedisURI host = toURI(ip, port);
@ -409,7 +409,7 @@ public class SentinelConnectionManager extends MasterSlaveConnectionManager {
String ip = map.get("ip"); String ip = map.get("ip");
String port = map.get("port"); String port = map.get("port");
String flags = map.get("flags"); String flags = map.getOrDefault("flags", "");
String masterHost = map.get("master-host"); String masterHost = map.get("master-host");
String masterPort = map.get("master-port"); String masterPort = map.get("master-port");
@ -464,7 +464,7 @@ public class SentinelConnectionManager extends MasterSlaveConnectionManager {
} }
Set<RedisURI> newUris = list.stream().filter(m -> { Set<RedisURI> newUris = list.stream().filter(m -> {
String flags = m.get("flags"); String flags = m.getOrDefault("flags", "");
if (!m.isEmpty() && !flags.contains("disconnected") && !flags.contains("s_down")) { if (!m.isEmpty() && !flags.contains("disconnected") && !flags.contains("s_down")) {
return true; return true;
} }

Loading…
Cancel
Save