From 5e7f029dbfebfe13d26dd1865a57f9662e91c765 Mon Sep 17 00:00:00 2001 From: Matt Cavanagh Date: Fri, 28 Apr 2023 01:48:46 +0100 Subject: [PATCH] Added rabbitMQ module booting debug --- src/modules/rabbitmq/RabbitMQModule.ts | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/src/modules/rabbitmq/RabbitMQModule.ts b/src/modules/rabbitmq/RabbitMQModule.ts index ccf281d1..cda96795 100644 --- a/src/modules/rabbitmq/RabbitMQModule.ts +++ b/src/modules/rabbitmq/RabbitMQModule.ts @@ -1,4 +1,4 @@ -import {Module, OnApplicationBootstrap} from '@nestjs/common'; +import {Logger, Module, OnApplicationBootstrap} from '@nestjs/common'; import {connect} from 'amqp-connection-manager'; import {TYPES} from '../../constants/types'; import ApiMQPublisher from './publishers/ApiMQPublisher'; @@ -43,6 +43,8 @@ import MetricsModule from '../metrics/MetricsModule'; ], }) export default class RabbitMQModule implements OnApplicationBootstrap { + private readonly logger = new Logger('Redis'); + constructor( private readonly apiMqPublisher: ApiMQPublisher, private readonly apiMqDelayPublisher: ApiMQDelayPublisher, @@ -50,10 +52,11 @@ export default class RabbitMQModule implements OnApplicationBootstrap { } public async onApplicationBootstrap() { - + this.logger.debug('Booting RabbitMQModule...'); await Promise.all([ this.apiMqPublisher.connect(), this.apiMqDelayPublisher.connect(), ]); + this.logger.debug('RabbitMQModule booted!'); } }