From e47d3a88ef942cb0fddd93c5e709e147ddd522c8 Mon Sep 17 00:00:00 2001
From: AdisakKanthawilang <adisak@frappet.com>
Date: Mon, 25 Nov 2024 11:27:30 +0700
Subject: [PATCH] test rabbit

---
 src/services/rabbitmq.ts | 19 +++++++++++--------
 1 file changed, 11 insertions(+), 8 deletions(-)

diff --git a/src/services/rabbitmq.ts b/src/services/rabbitmq.ts
index 49375f5f..0dfdfc85 100644
--- a/src/services/rabbitmq.ts
+++ b/src/services/rabbitmq.ts
@@ -24,10 +24,12 @@ export async function init() {
   const channel = await connection.createChannel(); //----> (1.4) create Channel
 
   console.log(channel ? "[AMQ] Create channel success" : "[AMQ] Create channel failed");
-
-  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); 
+  
+  await Promise.all([
+    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)
+  ]); 
 
   sendToQueue = (payload: any, persistent = true) => {
     //----> (2) sendQueue To RabbitMQ and set persistent (if "true" redo the failed queue when server run again)
@@ -41,10 +43,11 @@ export async function init() {
   };
 
   console.log("[AMQ] Listening for message...");
-
-  await createConsumer(queue, channel, handler); //----> (3) Process Consumer
-  await createConsumer(queue_org, channel, handler_org);
-  // createConsumer(queue2, channel, handler2);
+  await Promise.all([
+    createConsumer(queue, channel, handler), //----> (3) Process Consumer
+    createConsumer(queue_org, channel, handler_org)
+    // createConsumer(queue2, channel, handler2);
+  ]);
 }
 
 let retries = 0;