From f9068ad867b8f91acf19319008a645c3c84867a9 Mon Sep 17 00:00:00 2001
From: Gabriele Toselli <toselli.gabriele@gmail.com>
Date: Tue, 4 Jun 2024 10:17:24 +0200
Subject: [PATCH] fix(ddd-toolkit-rabbit-bus): add missing on message log

---
 .changeset/fair-scissors-fail.md                        | 5 +++++
 packages/ddd-toolkit-rabbit-bus/src/rabbit-event-bus.ts | 2 ++
 2 files changed, 7 insertions(+)
 create mode 100644 .changeset/fair-scissors-fail.md

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