From 079362b1d01ffd27ca8d35d9be132176502478d9 Mon Sep 17 00:00:00 2001 From: AdisakKanthawilang Date: Tue, 24 Dec 2024 09:07:13 +0700 Subject: [PATCH] fix quere --- src/services/rabbitmq.ts | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/services/rabbitmq.ts b/src/services/rabbitmq.ts index 551a38f8..37a6899c 100644 --- a/src/services/rabbitmq.ts +++ b/src/services/rabbitmq.ts @@ -36,9 +36,9 @@ 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