diff --git a/src/app.module.ts b/src/app.module.ts index a8f8146..d74276d 100644 --- a/src/app.module.ts +++ b/src/app.module.ts @@ -5,10 +5,11 @@ import { WebhookController } from './controllers/webhook.controller'; import { WebhookService } from './services/webhook.service'; import { RabbitMQService } from './services/rabbit.service'; import { ConfigModule } from '@nestjs/config'; +import rabbitmqConfig from './config/rabbitmq.config'; @Module({ imports: [ - ConfigModule.forRoot({ isGlobal: true,load: [() => require('./config/rabbitmq.config').default()] }), + ConfigModule.forRoot({ isGlobal: true,load: [rabbitmqConfig] }), ], controllers: [AppController, WebhookController], providers: [AppService, WebhookService, RabbitMQService], diff --git a/config/rabbit.config.ts b/src/config/rabbitmq.config.ts similarity index 100% rename from config/rabbit.config.ts rename to src/config/rabbitmq.config.ts diff --git a/src/services/rabbit.service.ts b/src/services/rabbit.service.ts index f6853c5..7f6dbc4 100644 --- a/src/services/rabbit.service.ts +++ b/src/services/rabbit.service.ts @@ -18,7 +18,7 @@ export class RabbitMQService implements OnModuleInit { const pass = this.configService.get('rabbitmq.pass'); const host = this.configService.get('rabbitmq.host'); const port = this.configService.get('rabbitmq.port'); - + this.connection = await connect(`amqp://${user}:${pass}@${host}:${port}`); this.channel = await this.connection.createChannel(); console.log('Connected to RabbitMQ');