From 201e6f7e7bb20e41c6080322425a866d9241828d Mon Sep 17 00:00:00 2001
From: Davidson Gomes <davidsongviolao@gmail.com>
Date: Fri, 18 Aug 2023 10:38:32 -0300
Subject: [PATCH] Added rabbitmq to send events

---
 src/libs/amqp.server.ts                   | 4 +---
 src/whatsapp/services/whatsapp.service.ts | 7 ++-----
 2 files changed, 3 insertions(+), 8 deletions(-)

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',
             },
           });