diff --git a/src/main.ts b/src/main.ts index 1aab166..82784c2 100644 --- a/src/main.ts +++ b/src/main.ts @@ -4,14 +4,13 @@ class MqttMongo { private mqttClient : Mqtt.Client constructor() { - } - - exec(): void { this.mqttClient = Mqtt.connect(options['broker']) this.mqttClient.on('offline', () => { console.log("mqtt client is offline") }) this.mqttClient.on('reconnect', () => { console.log("mqtt client is reconnecting") }) this.mqttClient.on('close', () => { console.log("mqtt connection closed") }) + } + exec(): void { this.mqttClient.on('connect', () => { console.log("mqtt client connected to broker") this.mqttClient.subscribe('MqttMongo/Command') @@ -27,8 +26,6 @@ class MqttMongo { this.mqttClient.end() } }) - - console.log("Hello world") } } @@ -40,4 +37,6 @@ options .parse(process.argv) const mqttMongo = new MqttMongo() -mqttMongo.exec() \ No newline at end of file +mqttMongo.exec() + +console.log("MqttMongo started") \ No newline at end of file