Adapt to make compatible with current running services

Author: judsonjuniorr

src/config/env.config.ts

@@ -284,7 +284,7 @@ export class ConfigService {
       },
       RABBITMQ: {
         ENABLED: process.env?.RABBITMQ_ENABLED === 'true',
-        MODE: (process.env?.RABBITMQ_MODE as Rabbitmq['MODE']) || 'single',
+        MODE: (process.env?.RABBITMQ_MODE as Rabbitmq['MODE']) || 'isolated',
         EXCHANGE_NAME: process.env?.RABBITMQ_EXCHANGE_NAME || 'evolution_exchange',
         URI: process.env.RABBITMQ_URI || '',
       },

src/libs/amqp.server.ts

@@ -76,7 +76,7 @@ export const initQueues = (instanceName: string, events: string[]) => {
         autoDelete: false,
       });
 
-      const queueName = event;
+      const queueName = `${instanceName}.${event}`;
       amqp.assertQueue(queueName, {
         durable: true,
         autoDelete: false,
@@ -173,9 +173,8 @@ export const removeQueues = (instanceName: string, events: string[]) => {
         autoDelete: false,
       });
 
-      const queueName = event;
-
-      amqp.unbindQueue(queueName, exchangeName, event);
+      const queueName = `${instanceName}.${event}`;
+      amqp.deleteQueue(queueName);
     });
     amqp.deleteExchange(instanceName);
   }