From 5c2c898d825f1cef5f259b476b6fe4c97dd80040 Mon Sep 17 00:00:00 2001
From: AdisakKanthawilang <adisak@frappet.com>
Date: Fri, 22 Nov 2024 13:43:00 +0700
Subject: [PATCH] fix rabbit

---
 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 771d73d7..0908e907 100644
--- a/src/services/rabbitmq.ts
+++ b/src/services/rabbitmq.ts
@@ -49,7 +49,7 @@ export async function init() {
 
 let retries = 0;
 
-function createConsumer( //----> consumer
+async function createConsumer( //----> consumer
   queue: string,
   channel: amqp.Channel,
   handler: (msg: amqp.ConsumeMessage) => Promise<boolean> | boolean,