From b907d85a7e1f11579ba0c7b1edf0596be98ca9af Mon Sep 17 00:00:00 2001
From: Davidson Gomes <contato@agenciadgcode.com>
Date: Wed, 17 Jul 2024 18:55:35 -0300
Subject: [PATCH] Fix: Fixed global exchange name and updated database
 connection client name

This commit resolves an issue with the global exchange name and updates the database connection client name. The `.env.example`, `CHANGELOG.md`, and `src/api/integrations/rabbitmq/libs/amqp.server.ts` files were modified. The exchange name in the AMQP server and global queues initialization has been changed to use the value from the configuration service. Additionally, the database connection client name has been updated in the `.env.example` file. The change in the `CHANGELOG.md` file has been updated accordingly.
---
 .env.example                                      | 2 +-
 CHANGELOG.md                                      | 1 +
 src/api/integrations/rabbitmq/libs/amqp.server.ts | 4 ++--
 3 files changed, 4 insertions(+), 3 deletions(-)

diff --git a/.env.example b/.env.example
index 23557cbd9..81b8bf8a6 100644
--- a/.env.example
+++ b/.env.example
@@ -20,7 +20,7 @@ PROVIDER_PREFIX=evolution
 DATABASE_ENABLED=true
 DATABASE_PROVIDER=postgresql
 DATABASE_CONNECTION_URI='postgresql://user:pass@localhost:5432/evolution?schema=public'
-DATABASE_CONNECTION_CLIENT_NAME=evolution
+DATABASE_CONNECTION_CLIENT_NAME=evolution_exchange
 DATABASE_SAVE_DATA_INSTANCE=true
 DATABASE_SAVE_DATA_NEW_MESSAGE=true
 DATABASE_SAVE_MESSAGE_UPDATE=true
diff --git a/CHANGELOG.md b/CHANGELOG.md
index 2cfb9843d..68587061e 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -5,6 +5,7 @@
 * Fixed the function of saving or not saving data in the database
 * Resolve not find name
 * Removed DEL_TEMP_INSTANCES as it is not being used
+* Fixed global exchange name
 
 # 2.0.1-beta (2024-07-17 17:01)
 
diff --git a/src/api/integrations/rabbitmq/libs/amqp.server.ts b/src/api/integrations/rabbitmq/libs/amqp.server.ts
index 1aab9c6a8..34b1ae46c 100644
--- a/src/api/integrations/rabbitmq/libs/amqp.server.ts
+++ b/src/api/integrations/rabbitmq/libs/amqp.server.ts
@@ -23,7 +23,7 @@ export const initAMQP = () => {
           return;
         }
 
-        const exchangeName = 'evolution_exchange';
+        const exchangeName = configService.get<Rabbitmq>('RABBITMQ').EXCHANGE_NAME || 'evolution_exchange';
 
         channel.assertExchange(exchangeName, 'topic', {
           durable: true,
@@ -59,7 +59,7 @@ export const initGlobalQueues = () => {
 
     const queueName = `${event.replace(/_/g, '.').toLowerCase()}`;
     const amqp = getAMQP();
-    const exchangeName = 'evolution_exchange';
+    const exchangeName = configService.get<Rabbitmq>('RABBITMQ').EXCHANGE_NAME || 'evolution_exchange';
 
     amqp.assertExchange(exchangeName, 'topic', {
       durable: true,