diff --git a/src/libs/amqp.server.ts b/src/libs/amqp.server.ts index 6f4af528..cc0f13b5 100644 --- a/src/libs/amqp.server.ts +++ b/src/libs/amqp.server.ts @@ -27,10 +27,8 @@ export const initAMQP = () => { 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 597af126..49f51c44 100644 --- a/src/whatsapp/services/whatsapp.service.ts +++ b/src/whatsapp/services/whatsapp.service.ts @@ -597,14 +597,11 @@ export class WAStartupService { if (amqp) { if (Array.isArray(rabbitmqLocal) && rabbitmqLocal.includes(we)) { - const exchangeName = 'evolution_exchange'; + const exchangeName = this.instanceName ?? 'evolution_exchange'; amqp.assertExchange(exchangeName, 'topic', { durable: true, autoDelete: false, - arguments: { - queueType: 'quorum', - }, }); const queueName = `${this.instanceName}.${event}`; @@ -613,7 +610,7 @@ export class WAStartupService { durable: true, autoDelete: false, arguments: { - queueType: 'quorum', + 'x-queue-type': 'quorum', }, });