From 872584c0d6eba9e25e6f99e2f3b5e744012a0751 Mon Sep 17 00:00:00 2001
From: AdisakKanthawilang <adisak@frappet.com>
Date: Mon, 24 Feb 2025 14:47:09 +0700
Subject: [PATCH] comment rabbit

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

diff --git a/src/services/rabbitmq.ts b/src/services/rabbitmq.ts
index d394844c..7b1d35dd 100644
--- a/src/services/rabbitmq.ts
+++ b/src/services/rabbitmq.ts
@@ -11,12 +11,11 @@ import { Profile } from "../entities/Profile";
 
 export let sendToQueue: (payload: any) => void;
 export let sendToQueueOrg: (payload: any) => void;
-export let sendToQueueOrgReport: (payload: any) => void;
 export async function init() {
   //----> (1) Producer
-  if (!process.env.AMQ_URL || !process.env.AMQ_QUEUE || !process.env.AMQ_QUEUE_ORG || !process.env.AMQ_QUEUE_REPORT) return;
+  if (!process.env.AMQ_URL || !process.env.AMQ_QUEUE || !process.env.AMQ_QUEUE_ORG) return;
 
-  const { AMQ_URL: url, AMQ_QUEUE: queue, AMQ_QUEUE_ORG: queue_org, AMQ_QUEUE_REPORT: queue_org_report } = process.env; //----> (1.2) get url and queue from .env
+  const { AMQ_URL: url, AMQ_QUEUE: queue, AMQ_QUEUE_ORG: queue_org } = process.env; //----> (1.2) get url and queue from .env
 
   const connection = await amqp.connect(url); //----> (1.3) set up url with amqp protocol
 
@@ -41,14 +40,9 @@ export async function init() {
     channel.sendToQueue(queue_org, Buffer.from(JSON.stringify(payload)), { persistent });
   };
 
-  sendToQueueOrgReport = (payload: any, persistent = true) => {
-    channel.sendToQueue(queue_org_report, Buffer.from(JSON.stringify(payload)), { persistent });
-  };
-
   console.log("[AMQ] Listening for message...");
   createConsumer(queue, channel, handler), //----> (3) Process Consumer
   createConsumer(queue_org, channel, handler_org);
-  createConsumer(queue_org_report, channel, handler_org_report);
   // createConsumer(queue2, channel, handler2);
 }
 
@@ -180,16 +174,3 @@ async function handler_org(msg: amqp.ConsumeMessage): Promise<boolean> {
   }
 }
 
-async function handler_org_report(msg: amqp.ConsumeMessage): Promise<boolean> {
-  //----> condition before process consume
-  const { data, token, user } = JSON.parse(msg.content.toString());
-  const { id, status, lastUpdateUserId, lastUpdateFullName, lastUpdatedAt } = data;
-  try {
-    
-    console.log("[AMQ] Excecute Organization Success");
-    return true;
-  } catch (error) {
-    console.error(error);
-    return false;
-  }
-}