wn/MqttMongoNodejs
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

command line option added

Browse Source
This commit is contained in:
Wolfgang Hottgenroth 2017-04-28 22:19:03 +02:00
parent b6e34999b1
commit 14acc50732
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/main.ts
View File

@ -8,11 +8,16 @@ class MqttMongo {
exec(): void { exec(): void {
this.mqttClient = Mqtt.connect(options['broker']) 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") })
this.mqttClient.on('connect', () => { this.mqttClient.on('connect', () => {
console.log("connected to broker") console.log("mqtt client connected to broker")
this.mqttClient.subscribe('MqttMongo/Command') this.mqttClient.subscribe('MqttMongo/Command')
this.mqttClient.publish('MqttMongo/Status', 'hello, started up') this.mqttClient.publish('MqttMongo/Status', 'hello, started up')
}) })
this.mqttClient.on('message', (topic : string, message : string) => { this.mqttClient.on('message', (topic : string, message : string) => {
console.log("message received") console.log("message received")
console.log("topic %s", topic) console.log("topic %s", topic)
@ -22,9 +27,6 @@ class MqttMongo {
this.mqttClient.end() this.mqttClient.end()
} }
}) })
this.mqttClient.on('close', () => {
console.log("bye bye")
})
console.log("Hello world") console.log("Hello world")
} }