From 7627cb441de85471b906b87c133b338f2a78ef20 Mon Sep 17 00:00:00 2001 From: Nikita Koksharov Date: Wed, 23 Nov 2022 10:12:28 +0300 Subject: [PATCH] Fixed - pubsub/updates broken after AWS Elasticache cluster failover. #4653 --- .../java/org/redisson/cluster/ClusterConnectionManager.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/redisson/src/main/java/org/redisson/cluster/ClusterConnectionManager.java b/redisson/src/main/java/org/redisson/cluster/ClusterConnectionManager.java index a22598bf1..9f50e27d7 100644 --- 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 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; });