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);