From 8dc18d744d05c1106c41d817ab6e14f451096c5f Mon Sep 17 00:00:00 2001 From: kittapath Date: Fri, 15 Nov 2024 14:54:58 +0700 Subject: [PATCH 1/2] no message --- src/controllers/OrganizationDotnetController.ts | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/controllers/OrganizationDotnetController.ts b/src/controllers/OrganizationDotnetController.ts index b6308228..23e6a870 100644 --- a/src/controllers/OrganizationDotnetController.ts +++ b/src/controllers/OrganizationDotnetController.ts @@ -633,6 +633,7 @@ export class OrganizationDotnetController extends Controller { currentZipCode: profile.currentZipCode, dutyTimeId: profile.dutyTimeId, dutyTimeEffectiveDate: profile.dutyTimeEffectiveDate, + amountd: profile.amount, root: profile?.current_holders?.find( (x) => @@ -716,6 +717,7 @@ export class OrganizationDotnetController extends Controller { currentZipCode: profile.currentZipCode, dutyTimeId: profile.dutyTimeId, dutyTimeEffectiveDate: profile.dutyTimeEffectiveDate, + amountd: profile.amount, root: profile?.current_holders?.find( (x) => From a3ce676d40f4e3facf011bbfd53563ed5136ee1f Mon Sep 17 00:00:00 2001 From: waruneeauy Date: Fri, 15 Nov 2024 15:13:52 +0700 Subject: [PATCH 2/2] 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);