refactor message broker

src/modules/configuration/adapters/primaries/configuration-messager.controller.ts

@@ -16,9 +16,7 @@ export class ConfigurationMessagerController {
   ) {}
 
   @RabbitSubscribe({
-    exchange: 'configuration',
+    name: 'setConfiguration',
-    routingKey: ['create', 'update'],
-    queue: 'user-configuration-update',
   })
   public async setConfigurationHandler(message: string) {
     const configuration: Configuration = JSON.parse(message);
@@ -38,9 +36,7 @@ export class ConfigurationMessagerController {
   }
 
   @RabbitSubscribe({
-    exchange: 'configuration',
+    name: 'deleteConfiguration',
-    routingKey: 'delete',
-    queue: 'user-configuration-delete',
   })
   public async configurationDeletedHandler(message: string) {
     const deletedConfiguration: Configuration = JSON.parse(message);
@@ -58,9 +54,7 @@ export class ConfigurationMessagerController {
   }
 
   @RabbitSubscribe({
-    exchange: 'configuration',
+    name: 'propagateConfiguration',
-    routingKey: 'propagate',
-    queue: 'user-configuration-propagate',
   })
   public async propagateConfigurationsHandler(message: string) {
     const configurations: Array<Configuration> = JSON.parse(message);

src/modules/configuration/configuration.module.ts

@@ -32,10 +32,24 @@ import { SetConfigurationUseCase } from './domain/usecases/set-configuration.use
       ): Promise<RabbitMQConfig> => ({
         exchanges: [
           {
-            name: 'configuration',
+            name: configService.get<string>('RMQ_EXCHANGE'),
             type: 'topic',
           },
         ],
+        handlers: {
+          setConfiguration: {
+            exchange: configService.get<string>('RMQ_EXCHANGE'),
+            routingKey: ['configuration.create', 'configuration.update'],
+          },
+          deleteConfiguration: {
+            exchange: configService.get<string>('RMQ_EXCHANGE'),
+            routingKey: 'configuration.delete',
+          },
+          propagateConfiguration: {
+            exchange: configService.get<string>('RMQ_EXCHANGE'),
+            routingKey: 'configuration.propagate',
+          },
+        },
         uri: configService.get<string>('RMQ_URI'),
         connectionInitOptions: { wait: false },
         enableControllerDiscovery: true,