redis/node-redis
1
0
Fork 0
mirror of https://github.com/redis/node-redis.git synced 2025-08-07 13:22:56 +03:00
Code Activity

Disable readOnly for cluster s/pubsub client 4.7 (#2951)

Browse Source
This commit is contained in:
Hristo Temelski
2025-05-08 10:29:12 +03:00
committed by GitHub
parent 2fc79bdfb3
commit e267dce19c
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
packages/client/lib/cluster/cluster-slots.ts
View File

@@ -535,7 +535,7 @@ export default class RedisClusterSlots<
this.pubSubNode = { this.pubSubNode = {
address: node.address, address: node.address,
client: this.#createClient(node, true) client: this.#createClient(node, false)
.then(async client => { .then(async client => {
if (toResubscribe) { if (toResubscribe) {
await Promise.all([ await Promise.all([
@@ -574,7 +574,7 @@ export default class RedisClusterSlots<
} }
#initiateShardedPubSubClient(master: MasterNode<M, F, S>) { #initiateShardedPubSubClient(master: MasterNode<M, F, S>) {
const promise = this.#createClient(master, true) const promise = this.#createClient(master, false)
.then(client => { .then(client => {
client.on('server-sunsubscribe', async (channel, listeners) => { client.on('server-sunsubscribe', async (channel, listeners) => {
try { try {