fix(ddd-toolkit-rabbit-bus): add missing on message log

fizzbuds · Jun 4, 2024 · f9068ad · f9068ad
1 parent 348d829
commit f9068ad
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 0 deletions.
diff --git a/.changeset/fair-scissors-fail.md 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
@@ -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`);