diff --git a/src/libs/amqp.server.ts b/src/libs/amqp.server.ts index 86819c80..6f4af528 100644 --- a/src/libs/amqp.server.ts +++ b/src/libs/amqp.server.ts @@ -24,7 +24,13 @@ export const initAMQP = () => { const exchangeName = 'evolution_exchange'; - channel.assertExchange(exchangeName, 'topic', { durable: false }); + channel.assertExchange(exchangeName, 'topic', { + durable: true, + autoDelete: false, + arguments: { + queueType: 'quorum', + }, + }); amqpChannel = channel; logger.info('AMQP initialized'); diff --git a/src/whatsapp/services/whatsapp.service.ts b/src/whatsapp/services/whatsapp.service.ts index b71d8762..597af126 100644 --- a/src/whatsapp/services/whatsapp.service.ts +++ b/src/whatsapp/services/whatsapp.service.ts @@ -601,9 +601,9 @@ export class WAStartupService { amqp.assertExchange(exchangeName, 'topic', { durable: true, - 'auto-delete': false, + autoDelete: false, arguments: { - 'x-queue-type': 'quorum', + queueType: 'quorum', }, });