From a45f97e268dfd0a88036a1671c37486846076f76 Mon Sep 17 00:00:00 2001
From: AdisakKanthawilang <adisak@frappet.com>
Date: Mon, 18 Nov 2024 11:01:44 +0700
Subject: [PATCH] =?UTF-8?q?=E0=B8=97=E0=B8=94=E0=B8=A5=E0=B8=AD=E0=B8=87?=
 =?UTF-8?q?=E0=B8=9B=E0=B8=B4=E0=B8=94=20channel.prefetch?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/services/rabbitmq.ts | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/services/rabbitmq.ts b/src/services/rabbitmq.ts
index d7cc555a..9919eeb8 100644
--- a/src/services/rabbitmq.ts
+++ b/src/services/rabbitmq.ts
@@ -27,7 +27,7 @@ export async function init() {
 
   channel.assertQueue(queue, { durable: true }); //----> (1.5) assert queue and set durable (if "true" save to disk on RabbitMQ)
   channel.assertQueue(queue_org, { durable: true });
-  channel.prefetch(1);
+  // channel.prefetch(1); 
 
   sendToQueue = (payload: any, persistent = true) => {
     //----> (2) sendQueue To RabbitMQ and set persistent (if "true" redo the failed queue when server run again)