From 0c70fe006f601de24a2eb035006adbc98adbed95 Mon Sep 17 00:00:00 2001 From: AdisakKanthawilang Date: Mon, 18 Nov 2024 11:25:50 +0700 Subject: [PATCH] test --- src/services/rabbitmq.ts | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/services/rabbitmq.ts b/src/services/rabbitmq.ts index 9919eeb8..1ccebf45 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) @@ -42,8 +42,8 @@ export async function init() { console.log("[AMQ] Listening for message..."); - createConsumer(queue, channel, handler); //----> (3) Process Consumer - createConsumer(queue_org, channel, handler_org); + await createConsumer(queue, channel, handler); //----> (3) Process Consumer + await createConsumer(queue_org, channel, handler_org); // createConsumer(queue2, channel, handler2); }