amirho/nest
1
0
Fork 0
mirror of https://github.com/nestjs/nest.git synced 2026-02-21 23:11:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat(microservices): Kafka controller await client consumers connect

Browse Source
This commit is contained in:
Michael Kaufman
2020-10-31 17:39:00 -04:00
parent da13cca8cd
commit a85cb0fe4b
4 changed files with 140 additions and 33382 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
packages/microservices/server/server-kafka.ts
View File

@@ -71,9 +71,9 @@ export class ServerKafka extends Server implements CustomTransportStrategy {
await this.start(callback);
}
public close(): void {
this.consumer && this.consumer.disconnect();
this.producer && this.producer.disconnect();
public async close(): Promise<void> {
this.consumer && (await this.consumer.disconnect());
this.producer && (await this.producer.disconnect());
this.consumer = null;
this.producer = null;
this.client = null;