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): move getTransportId functions to public variable transportId and make it optional

Browse Source
This commit is contained in:
alex
2020-05-16 15:22:15 +03:00
parent 0845dab3a3
commit e2c8f74f19
13 changed files with 16 additions and 37 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -38,6 +38,7 @@ export class ServerKafka extends Server implements CustomTransportStrategy {
private readonly brokers: string[];
private readonly clientId: string;
private readonly groupId: string;
public readonly transportId: Transport = Transport.KAFKA;
constructor(private readonly options: KafkaOptions['options']) {
super();
@@ -63,10 +64,6 @@ export class ServerKafka extends Server implements CustomTransportStrategy {
this.initializeDeserializer(options);
}
public getTransport(): number {
return Transport.KAFKA;
}
public async listen(callback: () => void): Promise<void> {
this.client = this.createClient();
await this.start(callback);