diff --git a/.changeset/fair-scissors-fail.md b/.changeset/fair-scissors-fail.md new file mode 100644 index 0000000..9f3d8b2 --- /dev/null +++ b/.changeset/fair-scissors-fail.md @@ -0,0 +1,5 @@ +--- +"@fizzbuds/ddd-toolkit-rabbit-bus": patch +--- + +add log on message cb diff --git a/packages/ddd-toolkit-rabbit-bus/src/rabbit-event-bus.ts b/packages/ddd-toolkit-rabbit-bus/src/rabbit-event-bus.ts index 2320ef2..b076d61 100644 --- a/packages/ddd-toolkit-rabbit-bus/src/rabbit-event-bus.ts +++ b/packages/ddd-toolkit-rabbit-bus/src/rabbit-event-bus.ts @@ -88,6 +88,8 @@ export class RabbitEventBus implements IEventBus { return; } + this.logger.debug(`Received message ${rawMessage.content.toString()} on queue ${queueName}`); + if (!this.isAValidMessage(parsedMessage)) { this.connection.getChannel().nack(rawMessage, false, false); this.logger.warn(`Message discarded due to invalid format`);