Fixed - different topics subscribed to the same Redis node in Cluster.

pull/2954/head
Nikita Koksharov
parent 9fa6ce3ac7
commit ee53118dd8

@ -586,6 +586,8 @@ public class MasterSlaveConnectionManager implements ConnectionManager {
entry.getAllEntries().forEach(e -> entry.nodeDown(e));
entry.masterDown();
entry.shutdownAsync();
subscribeService.remove(entry);
String slaves = entry.getAllEntries().stream()
.filter(e -> !e.getClient().getAddr().equals(entry.getClient().getAddr()))
.map(e -> e.getClient().toString())

@ -400,6 +400,10 @@ public class PublishSubscribeService {
return result;
}
public void remove(MasterSlaveEntry entry) {
freePubSubMap.remove(entry);
}
public RFuture<Codec> unsubscribe(ChannelName channelName, PubSubType topicType) {
if (connectionManager.isShuttingDown()) {
return RedissonPromise.newSucceededFuture(null);

Loading…
Cancel
Save