diff --git a/packages/client/lib/cluster/cluster-slots.ts b/packages/client/lib/cluster/cluster-slots.ts index 45c96a80b5..2c8eb737c2 100644 --- a/packages/client/lib/cluster/cluster-slots.ts +++ b/packages/client/lib/cluster/cluster-slots.ts @@ -535,7 +535,7 @@ export default class RedisClusterSlots< this.pubSubNode = { address: node.address, - client: this.#createClient(node, true) + client: this.#createClient(node, false) .then(async client => { if (toResubscribe) { await Promise.all([ @@ -574,7 +574,7 @@ export default class RedisClusterSlots< } #initiateShardedPubSubClient(master: MasterNode) { - const promise = this.#createClient(master, true) + const promise = this.#createClient(master, false) .then(client => { client.on('server-sunsubscribe', async (channel, listeners) => { try {