From c4d41134b866cd3b0ed921963a7d83b652c0a2b0 Mon Sep 17 00:00:00 2001 From: Davidson Gomes Date: Fri, 18 Aug 2023 09:33:17 -0300 Subject: [PATCH] Messages sent by the api now arrive in chatwoot --- src/libs/amqp.server.ts | 8 +++++++- src/whatsapp/services/whatsapp.service.ts | 4 ++-- 2 files changed, 9 insertions(+), 3 deletions(-) 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', }, });