From 76f5a9fe4d8d821ca081f2ada60c437cc9c0afd1 Mon Sep 17 00:00:00 2001
From: AdisakKanthawilang <adisak@frappet.com>
Date: Wed, 30 Oct 2024 10:49:58 +0700
Subject: [PATCH] fix rabbit

---
 src/services/rabbitmq.ts | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

diff --git a/src/services/rabbitmq.ts b/src/services/rabbitmq.ts
index 1ad374b4..8bd75016 100644
--- a/src/services/rabbitmq.ts
+++ b/src/services/rabbitmq.ts
@@ -43,6 +43,8 @@ export async function init() {
   // createConsumer(queue2, channel, handler2);
 }
 
+let retries = 0;
+
 function createConsumer( //----> consumer
   queue: string,
   channel: amqp.Channel,
@@ -53,7 +55,10 @@ function createConsumer( //----> consumer
     async (msg) => {
       if (!msg) return;
 
-      if (await handler(msg)) return channel.ack(msg);
+      if ((await handler(msg)) || retries++ >= 3) {
+        retries = 0;
+        return channel.ack(msg);
+      }
 
       return await new Promise((resolve) => setTimeout(() => resolve(channel.nack(msg)), 3000));
     },
@@ -162,6 +167,6 @@ async function handler_org(msg: amqp.ConsumeMessage): Promise<boolean> {
     return true;
   } catch (error) {
     console.error(error);
-    return false; 
+    return false;
   }
 }