Merge branch 'develop' into adiDev
This commit is contained in:
commit
3cb06d9e19
2 changed files with 6 additions and 0 deletions
|
|
@ -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) =>
|
||||
|
|
|
|||
|
|
@ -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);
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue