Skip to content

Commit 55a410f

Browse files
authored
fix(ssubscribe): re-subscribe sharded pubsub channels individually on ready (#2012)
1 parent 5befe70 commit 55a410f

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

lib/redis/event_handler.ts

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -291,8 +291,10 @@ export function readyHandler(self) {
291291
}
292292
const ssubscribeChannels = condition.subscriber.channels("ssubscribe");
293293
if (ssubscribeChannels.length) {
294-
debug("ssubscribe %d channels", ssubscribeChannels.length);
295-
self.ssubscribe(ssubscribeChannels);
294+
debug("ssubscribe %s", ssubscribeChannels.length);
295+
for (const channel of ssubscribeChannels) {
296+
self.ssubscribe(channel);
297+
}
296298
}
297299
}
298300
}

0 commit comments

Comments
 (0)