Skip to content
This repository has been archived by the owner on Jul 15, 2024. It is now read-only.

Commit

Permalink
fix(ProcessBootstrapper): debug owned shards
Browse files Browse the repository at this point in the history
  • Loading branch information
Hazmi35 authored Feb 24, 2024
1 parent d9480b7 commit 7f7a073
Showing 1 changed file with 1 addition and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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);
Expand Down

0 comments on commit 7f7a073

Please sign in to comment.