How do you inject and use a ClientProxy to communicate with another microservice in NestJS?

Q: How do you inject and use a ClientProxy to communicate with another microservice in NestJS?

// Module — register the client @Module({ imports: [ ClientsModule.register([ { name: 'USERS_SERVICE', transport: Transport.TCP, options: { host: 'users-service', port: 3001 }, }, ]), ], providers: [OrdersService], }) export class OrdersModule {} // Service — inject and use @Injectable() export class OrdersService implements OnModuleInit { constructor( @Inject('USERS_SERVICE') private client: ClientProxy, ) {} async onModuleInit() { await this.client.connect(); // establish transport connection } async getUser(id: number): Promise { return firstValueFrom( this.client.send ({ cmd: 'get_user' }, { id }), ); } notifyUserCreated(user: User): void { this.client.emit('user_created', user).subscribe(); } } ClientsModule.registerAsync() supports async factory with ConfigService injection for dynamic credentials. Call client.connect() in onModuleInit() — TCP and RabbitMQ require an explicit connection before sending. firstValueFrom() converts the Observable returned by send() to a Promise for async/await code. The name token ('USERS_SERVICE') must match the provide value in ClientsModule.register(). ClientProxyFactory.create() creates a client instance programmatically without the module system.

Difficulty: 6/10

ClientProxy injection, Microservice communication, NestJS providers

Register the client in the module using ClientsModule.register() with a name token and transport options. Inject it via @Inject('SERVICE_NAME') and call client.connect() in onModuleInit() for transports that require an explicit connection. Use client.send() for request-response and client.emit() for events.

ClientProxy registration and usage

ClientProxy usage rules:

1
ClientsModule.registerAsync() supports async factory with ConfigService injection for dynamic credentials.
2
Call client.connect() in onModuleInit() — TCP and RabbitMQ require an explicit connection before sending.

How do you inject and use a ClientProxy to communicate with another microservice in NestJS?

Difficulty: 6/10

ClientProxy injection, Microservice communication, NestJS providers

Register the client in the module using ClientsModule.register() with a name token and transport options. Inject it via @Inject('SERVICE_NAME') and call client.connect() in onModuleInit() for transports that require an explicit connection. Use client.send() for request-response and client.emit() for events.

ClientProxy registration and usage

ClientProxy usage rules:

1
ClientsModule.registerAsync() supports async factory with ConfigService injection for dynamic credentials.
2
Call client.connect() in onModuleInit() — TCP and RabbitMQ require an explicit connection before sending.

How do you inject and use a ClientProxy to communicate with another microservice in NestJS?

How do you inject and use a ClientProxy to communicate with another microservice in NestJS?

Scenario Questions

Follow-up Questions