diff --git a/src/services/rabbitmq.ts b/src/services/rabbitmq.ts index 54f82885..ca51655e 100644 --- a/src/services/rabbitmq.ts +++ b/src/services/rabbitmq.ts @@ -72,6 +72,7 @@ function createConsumer( //----> consumer } async function handler(msg: amqp.ConsumeMessage): Promise { + console.log(msg ? "[AMQ] on handler" : "[AMQ] don't handler"); //----> condition before process consumer const repo = AppDataSource.getRepository(Command); const { data, token, user } = JSON.parse(msg.content.toString());