hrms-bangkok/hrms-api-org
7
0
Fork 0
Code Issues Pull requests Projects Releases Packages 1 Wiki Activity Actions

fix

Browse source
This commit is contained in:
AdisakKanthawilang 2024-10-30 15:38:29 +07:00
parent e3be2c4c62
commit 61a532cae8
1 changed files with 4 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

8
src/services/rabbitmq.ts
View file

@ -32,14 +32,14 @@ export async function init() {
}); });
}; };
// sendToQueueOrg = (payload: any, persistent = true) => { sendToQueueOrg = (payload: any, persistent = true) => {
// channel.sendToQueue(queue_org, Buffer.from(JSON.stringify(payload)), { persistent }); channel.sendToQueue(queue_org, Buffer.from(JSON.stringify(payload)), { persistent });
// }; };
console.log("[AMQ] Listening for message..."); console.log("[AMQ] Listening for message...");
createConsumer(queue, channel, handler); //----> (3) Process Consumer createConsumer(queue, channel, handler); //----> (3) Process Consumer
// createConsumer(queue_org, channel, handler_org); createConsumer(queue_org, channel, handler_org);
// createConsumer(queue2, channel, handler2); // createConsumer(queue2, channel, handler2);
} }