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

tests(@nestjs) fix broken unit tests

Browse Source
This commit is contained in:
Kamil Myśliwiec
2018-03-24 20:55:06 +01:00
parent fdbf364087
commit e50ddf9cb9
23 changed files with 196 additions and 80 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
packages/microservices/server/server-mqtt.ts
View File

@@ -18,6 +18,8 @@ import {
} from './../constants';
import { ReadPacket } from '@nestjs/microservices';
let mqttPackage: any = {};
export class ServerMqtt extends Server implements CustomTransportStrategy {
private readonly url: string;
private mqttClient: mqtt.MqttClient;
@@ -25,8 +27,9 @@ export class ServerMqtt extends Server implements CustomTransportStrategy {
constructor(private readonly options: MicroserviceOptions) {
super();
this.url =
this.getOptionsProp<MqttOptions>(options, 'url') ||
MQTT_DEFAULT_URL;
this.getOptionsProp<MqttOptions>(options, 'url') || MQTT_DEFAULT_URL;
mqttPackage = this.loadPackage('mqtt', ServerMqtt.name);
}
public async listen(callback: () => void) {
@@ -54,8 +57,7 @@ export class ServerMqtt extends Server implements CustomTransportStrategy {
}
public createMqttClient(): mqtt.MqttClient {
return mqtt.connect(this.url, this.options
.options as MqttOptions);
return mqttPackage.connect(this.url, this.options.options as MqttOptions);
}
public getMessageHandler(pub: mqtt.MqttClient): any {