Skip to content

Commit c4d4113

Browse files
committed
Messages sent by the api now arrive in chatwoot
1 parent 680c92e commit c4d4113

File tree

2 files changed

+9
-3
lines changed

2 files changed

+9
-3
lines changed

src/libs/amqp.server.ts

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,13 @@ export const initAMQP = () => {
2424

2525
const exchangeName = 'evolution_exchange';
2626

27-
channel.assertExchange(exchangeName, 'topic', { durable: false });
27+
channel.assertExchange(exchangeName, 'topic', {
28+
durable: true,
29+
autoDelete: false,
30+
arguments: {
31+
queueType: 'quorum',
32+
},
33+
});
2834
amqpChannel = channel;
2935

3036
logger.info('AMQP initialized');

src/whatsapp/services/whatsapp.service.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -601,9 +601,9 @@ export class WAStartupService {
601601

602602
amqp.assertExchange(exchangeName, 'topic', {
603603
durable: true,
604-
'auto-delete': false,
604+
autoDelete: false,
605605
arguments: {
606-
'x-queue-type': 'quorum',
606+
queueType: 'quorum',
607607
},
608608
});
609609

0 commit comments

Comments
 (0)