From 7f7a073474099c3d721812150db6c684d20565c3 Mon Sep 17 00:00:00 2001 From: hzmi Date: Sat, 24 Feb 2024 09:48:06 +0000 Subject: [PATCH] fix(ProcessBootstrapper): debug owned shards --- .../src/Utilities/WebSockets/ProcessBootstrapper.ts | 1 + 1 file changed, 1 insertion(+) diff --git a/services/kanao-gateway/src/Utilities/WebSockets/ProcessBootstrapper.ts b/services/kanao-gateway/src/Utilities/WebSockets/ProcessBootstrapper.ts index 4e7be2e4..49f9ea15 100644 --- a/services/kanao-gateway/src/Utilities/WebSockets/ProcessBootstrapper.ts +++ b/services/kanao-gateway/src/Utilities/WebSockets/ProcessBootstrapper.ts @@ -130,6 +130,7 @@ export class ProcessBootstrapper { const content = JSON.parse(message.content.toString()) as { op: ShardOp; data: unknown; }; const shardId = ShardedRoutedQueue.routingKeyToShardId(message.fields.routingKey); this.logger.debug(content, `Received message from AMQP to shard ${shardId}`); + this.logger.debug(`Shard ${[...this.shards.keys()].join(", ")}`); if (shardId === null) return; if (!this.shards.has(shardId)) return; channel.ack(message);