Fixed - pubsub/updates broken after AWS Elasticache cluster failover. #4653

2 years ago · 7627cb441d
parent 9bdc2961af
commit 7627cb441d
1 changed files with 2 additions and 1 deletions
--- a/redisson/src/main/java/org/redisson/cluster/ClusterConnectionManager.java
+++ b/redisson/src/main/java/org/redisson/cluster/ClusterConnectionManager.java
@ -860,7 +860,8 @@ public class ClusterConnectionManager extends MasterSlaveConnectionManager {
            List<ClusterPartition> ps = partitions.values()
                    .stream()
                    .filter(cp -> cp.getType() == Type.MASTER
-                            && cp.getMasterAddress() != null)
+                                    && cp.getMasterAddress() != null
+                                        && ((!cp.slots().isEmpty() && partitions.size() == 1) || partitions.size() > 1))
                    .collect(Collectors.toList());
            return ps;
        });