This commit is contained in:
sbriat
2023-03-24 10:31:09 +01:00
parent b8308cfe37
commit 7818ce2d0a
3 changed files with 5 additions and 5 deletions

View File

@@ -12,7 +12,7 @@ export class AuthenticationMessagerController {
constructor(private readonly _commandBus: CommandBus) {}
@RabbitSubscribe({
name: 'user-update',
name: 'userUpdate',
})
public async userUpdatedHandler(message: string) {
const updatedUser = JSON.parse(message);
@@ -38,7 +38,7 @@ export class AuthenticationMessagerController {
}
@RabbitSubscribe({
name: 'user-delete',
name: 'userDelete',
})
public async userDeletedHandler(message: string) {
const deletedUser = JSON.parse(message);

View File

@@ -23,7 +23,6 @@ import { Messager } from './adapters/secondaries/messager';
CqrsModule,
RabbitMQModule.forRootAsync(RabbitMQModule, {
imports: [ConfigModule],
inject: [ConfigService],
useFactory: async (configService: ConfigService) => ({
exchanges: [
{
@@ -45,6 +44,7 @@ import { Messager } from './adapters/secondaries/messager';
connectionInitOptions: { wait: false },
enableControllerDiscovery: true,
}),
inject: [ConfigService],
}),
],
controllers: [AuthenticationController, AuthenticationMessagerController],