You've already forked node-redis
mirror of
https://github.com/redis/node-redis.git
synced 2025-08-07 13:22:56 +03:00
fix(pubsub): Fixed cluster client pubsub logic
* Infer the cluster pubsub client read only mode from the node type * Modify flag logic
This commit is contained in:
@@ -518,7 +518,7 @@ export default class RedisClusterSlots<
|
|||||||
node = index < this.masters.length ?
|
node = index < this.masters.length ?
|
||||||
this.masters[index] :
|
this.masters[index] :
|
||||||
this.replicas[index - this.masters.length],
|
this.replicas[index - this.masters.length],
|
||||||
client = this.#createClient(node, true);
|
client = this.#createClient(node, index >= this.masters.length);
|
||||||
|
|
||||||
this.pubSubNode = {
|
this.pubSubNode = {
|
||||||
address: node.address,
|
address: node.address,
|
||||||
|
Reference in New Issue
Block a user