diff --git a/src/services/rabbitmq.ts b/src/services/rabbitmq.ts index 0908e907..49375f5f 100644 --- a/src/services/rabbitmq.ts +++ b/src/services/rabbitmq.ts @@ -57,6 +57,7 @@ async function createConsumer( //----> consumer channel.consume( queue, async (msg) => { + console.log("[AMQ] MSQ",msg); if (!msg) return; if ((await handler(msg)) || retries++ >= 3) { retries = 0;