Skip to content

Commit 3a14fc3

Browse files
committed
adjust params rabbitmq
1 parent c364d3f commit 3a14fc3

File tree

1 file changed

+18
-2
lines changed

1 file changed

+18
-2
lines changed

src/whatsapp/services/whatsapp.service.ts

Lines changed: 18 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -599,11 +599,23 @@ export class WAStartupService {
599599
if (Array.isArray(rabbitmqLocal) && rabbitmqLocal.includes(we)) {
600600
const exchangeName = 'evolution_exchange';
601601

602-
amqp.assertExchange(exchangeName, 'topic', { durable: false });
602+
amqp.assertExchange(exchangeName, 'topic', {
603+
durable: true,
604+
'auto-delete': false,
605+
arguments: {
606+
'x-queue-type': 'quorum',
607+
},
608+
});
603609

604610
const queueName = `${this.instanceName}.${event}`;
605611

606-
amqp.assertQueue(queueName, { durable: false });
612+
amqp.assertQueue(queueName, {
613+
durable: true,
614+
'auto-delete': false,
615+
arguments: {
616+
'x-queue-type': 'quorum',
617+
},
618+
});
607619

608620
amqp.bindQueue(queueName, exchangeName, event);
609621

@@ -666,6 +678,7 @@ export class WAStartupService {
666678
instance: this.instance.name,
667679
data,
668680
destination: this.localWebhook.url,
681+
sender: this.wuid,
669682
server_url: serverUrl,
670683
apikey: (expose && instanceApikey) || null,
671684
};
@@ -685,6 +698,7 @@ export class WAStartupService {
685698
instance: this.instance.name,
686699
data,
687700
destination: this.localWebhook.url,
701+
sender: this.wuid,
688702
server_url: serverUrl,
689703
};
690704

@@ -734,6 +748,7 @@ export class WAStartupService {
734748
instance: this.instance.name,
735749
data,
736750
destination: localUrl,
751+
sender: this.wuid,
737752
server_url: serverUrl,
738753
};
739754

@@ -752,6 +767,7 @@ export class WAStartupService {
752767
instance: this.instance.name,
753768
data,
754769
destination: localUrl,
770+
sender: this.wuid,
755771
server_url: serverUrl,
756772
};
757773

0 commit comments

Comments
 (0)