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) => 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);