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

fix quere

Browse source
This commit is contained in:
AdisakKanthawilang 2024-12-24 09:07:13 +07:00
parent 2d42f926e4
commit 079362b1d0
1 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

6
src/services/rabbitmq.ts
View file

@ -36,9 +36,9 @@ 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