diff --git a/src/services/rabbitmq.ts b/src/services/rabbitmq.ts index 1ad374b4..39be698d 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); }