diff --git a/packages/microservices/server/server-mqtt.ts b/packages/microservices/server/server-mqtt.ts index 46a647a7a9c..7568e7f0678 100644 --- a/packages/microservices/server/server-mqtt.ts +++ b/packages/microservices/server/server-mqtt.ts @@ -29,8 +29,9 @@ let mqttPackage: any = {}; export class ServerMqtt extends Server implements CustomTransportStrategy { public readonly transportId = Transport.MQTT; + protected mqttClient: MqttClient; + private readonly url: string; - private mqttClient: MqttClient; constructor(private readonly options: MqttOptions['options']) { super(); diff --git a/packages/microservices/server/server-tcp.ts b/packages/microservices/server/server-tcp.ts index 7a14e60ba88..bffeb158a7c 100644 --- a/packages/microservices/server/server-tcp.ts +++ b/packages/microservices/server/server-tcp.ts @@ -28,10 +28,11 @@ import { Server } from './server'; export class ServerTCP extends Server implements CustomTransportStrategy { public readonly transportId = Transport.TCP; + protected server: NetSocket; + private readonly port: number; private readonly host: string; private readonly socketClass: Type; - private server: NetSocket; private isExplicitlyTerminated = false; private retryAttemptsCount = 0;