plug rabbit

src/app.module.ts

@@ -1,7 +1,9 @@
 import { Module } from '@nestjs/common';
+import { ConfigModule } from '@nestjs/config';
+import { LoggerModule } from './modules/logger.module';
 
 @Module({
-  imports: [],
+  imports: [ConfigModule.forRoot({ isGlobal: true }), LoggerModule],
   controllers: [],
   providers: [],
 })

src/modules/logger.module.ts

@@ -0,0 +1,27 @@
+import { Module } from '@nestjs/common';
+import { RabbitMQModule } from '@golevelup/nestjs-rabbitmq';
+import { ConfigModule, ConfigService } from '@nestjs/config';
+import { UserController } from './logger/adapters/primaries/user.controller';
+
+@Module({
+  imports: [
+    RabbitMQModule.forRootAsync(RabbitMQModule, {
+      imports: [ConfigModule],
+      useFactory: async (configService: ConfigService) => ({
+        exchanges: [
+          {
+            name: 'logging',
+            type: 'topic',
+          },
+        ],
+        uri: configService.get<string>('RMQ_URI'),
+        enableControllerDiscovery: true,
+      }),
+      inject: [ConfigService],
+    }),
+  ],
+  controllers: [UserController],
+  providers: [],
+  exports: [],
+})
+export class LoggerModule {}

src/modules/logger/adapters/primaries/user.controller.ts

@@ -0,0 +1,14 @@
+import { RabbitSubscribe } from '@golevelup/nestjs-rabbitmq';
+import { Controller } from '@nestjs/common';
+
+@Controller()
+export class UserController {
+  @RabbitSubscribe({
+    exchange: 'logging',
+    routingKey: 'user.create.*',
+    queue: 'logging-user',
+  })
+  public async userCreatedHandler(message: string) {
+    console.log(JSON.parse(message));
+  }
+}