diff --git a/src/services/rabbitmq.ts b/src/services/rabbitmq.ts index 37a6899c..551a38f8 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