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

log test

Browse source
This commit is contained in:
AdisakKanthawilang 2024-11-22 17:30:44 +07:00
parent 219a9ff104
commit e9554e14fa
1 changed files with 1 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

1
src/services/rabbitmq.ts
View file

@ -57,6 +57,7 @@ async function createConsumer( //----> consumer
channel.consume( channel.consume(
queue, queue,
async (msg) => { async (msg) => {
console.log("[AMQ] MSQ",msg);
if (!msg) return; if (!msg) return;
if ((await handler(msg)) || retries++ >= 3) { if ((await handler(msg)) || retries++ >= 3) {
retries = 0; retries = 0;