diff --git a/.env.example b/.env.example index 7825087d..ab9cf756 100644 --- a/.env.example +++ b/.env.example @@ -1,5 +1,6 @@ NODE_ENV=development SERVER_PORT=4000 +SERVER_CONSUMER_PORT=4001 POSTGRES_USER=postgres POSTGRES_PASSWORD=app123456 POSTGRES_DATABASE=languages diff --git a/src/consumer.ts b/src/consumer.ts index a6b53a17..b2cde21d 100644 --- a/src/consumer.ts +++ b/src/consumer.ts @@ -6,13 +6,21 @@ import * as dotenv from 'dotenv'; async function bootstrap() { dotenv.config(); + const port = process.env.SERVER_CONSUMER_PORT || 4001; - const rabbitMq = await NestFactory.createMicroservice(AppModule, { + const app = await NestFactory.create(AppModule); + + app.connectMicroservice({ + transport: Transport.TCP, + }); + + app.connectMicroservice({ transport: Transport.RMQ, options: rabbitMqConfig, }); - await rabbitMq.listen(); + await app.startAllMicroservices(); + await app.listen(port); } void bootstrap();