From 61a532cae850cad8bcba8eeec6735f01eb2a6724 Mon Sep 17 00:00:00 2001 From: AdisakKanthawilang Date: Wed, 30 Oct 2024 15:38:29 +0700 Subject: [PATCH] fix --- src/services/rabbitmq.ts | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/services/rabbitmq.ts b/src/services/rabbitmq.ts index 15ec316b..8bd75016 100644 --- a/src/services/rabbitmq.ts +++ b/src/services/rabbitmq.ts @@ -32,14 +32,14 @@ export async function init() { }); }; - // sendToQueueOrg = (payload: any, persistent = true) => { - // channel.sendToQueue(queue_org, Buffer.from(JSON.stringify(payload)), { persistent }); - // }; + sendToQueueOrg = (payload: any, persistent = true) => { + channel.sendToQueue(queue_org, Buffer.from(JSON.stringify(payload)), { persistent }); + }; console.log("[AMQ] Listening for message..."); createConsumer(queue, channel, handler); //----> (3) Process Consumer - // createConsumer(queue_org, channel, handler_org); + createConsumer(queue_org, channel, handler_org); // createConsumer(queue2, channel, handler2); }