diff --git a/packages/client/lib/client/commands-queue.ts b/packages/client/lib/client/commands-queue.ts index 52f86c6375..2ce48100ec 100644 --- a/packages/client/lib/client/commands-queue.ts +++ b/packages/client/lib/client/commands-queue.ts @@ -73,7 +73,10 @@ export default class RedisCommandsQueue { static #emitPubSubMessage(listenersMap: PubSubListenersMap, message: Buffer, channel: Buffer, pattern?: Buffer): void { const keyString = (pattern || channel).toString(), - listeners = listenersMap.get(keyString)!; + listeners = listenersMap.get(keyString); + + if (!listeners) return; + for (const listener of listeners.buffers) { listener(message, channel); }