From da8291c44df787c15fcdfc4a4586d1b986d16416 Mon Sep 17 00:00:00 2001 From: Pavel Pashov Date: Wed, 8 Oct 2025 12:34:31 +0300 Subject: [PATCH] fix: cluster.quit for sharded subscribers --- lib/cluster/index.ts | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/lib/cluster/index.ts b/lib/cluster/index.ts index 5957f049..f673a530 100644 --- a/lib/cluster/index.ts +++ b/lib/cluster/index.ts @@ -411,6 +411,10 @@ class Cluster extends EventEmitter { this.subscriber.stop(); + if (this.options.shardedSubscribers) { + this.shardedSubscribers.stop(); + } + const Promise = PromiseContainer.get(); if (status === "wait") { const ret = asCallback(Promise.resolve<"OK">("OK"), callback);