From a3ce676d40f4e3facf011bbfd53563ed5136ee1f Mon Sep 17 00:00:00 2001
From: waruneeauy <warunee.auy@gmail.com>
Date: Fri, 15 Nov 2024 15:13:52 +0700
Subject: [PATCH] add log rabbitmq connect & create chanel

---
 src/services/rabbitmq.ts | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/src/services/rabbitmq.ts b/src/services/rabbitmq.ts
index 8bd75016..ecd30f66 100644
--- a/src/services/rabbitmq.ts
+++ b/src/services/rabbitmq.ts
@@ -19,8 +19,12 @@ export async function init() {
 
   const connection = await amqp.connect(url); //----> (1.3) set up url with amqp protocol
 
+  console.log(connection ? "[AMQ] connection success" : "[AMQ] connection failed");
+
   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);