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

uptime fix

Browse Source
This commit is contained in:
Wolfgang Hottgenroth 2018-04-26 16:57:33 +02:00
parent d37e237de2
commit b86ab3d752
Signed by: wn
GPG Key ID: B586EAFCDF2F65F4
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/main.ts
View File

@ -35,10 +35,12 @@ class MqttMongo extends Events.EventEmitter {
private options : any private options : any
private msgCnt : number = 0 private msgCnt : number = 0
private startTime: Date
constructor(options : any) { constructor(options : any) {
super() super()
this.options = options this.options = options
this.startTime = new Date()
this.on('reconnectDatabase', this.connectToDatabase) this.on('reconnectDatabase', this.connectToDatabase)
} }
@ -47,7 +49,6 @@ class MqttMongo extends Events.EventEmitter {
private queue : Queue.Queue<MqttMessage.MqttMessage> = new Queue.Queue<MqttMessage.MqttMessage>() private queue : Queue.Queue<MqttMessage.MqttMessage> = new Queue.Queue<MqttMessage.MqttMessage>()
private mqttClient : Mqtt.Client private mqttClient : Mqtt.Client
private heartbeatTimer : NodeJS.Timer private heartbeatTimer : NodeJS.Timer
private uptime : number = 0
connectToDatabase() { connectToDatabase() {
console.info("About to connect to database") console.info("About to connect to database")
@ -145,8 +146,8 @@ class MqttMongo extends Events.EventEmitter {
setupHeartbeat() { setupHeartbeat() {
this.heartbeatTimer = setInterval(() => { this.heartbeatTimer = setInterval(() => {
this.uptime++ let uptime : number = (new Date().getTime() - this.startTime.getTime()) / 1000
let statusMsg = `{'Uptime': ${this.uptime}, 'MessageCount': ${this.msgCnt}}` let statusMsg = `{'Uptime': ${uptime}, 'MessageCount': ${this.msgCnt}}`
this.mqttClient.publish('MqttMongo/Status', statusMsg) this.mqttClient.publish('MqttMongo/Status', statusMsg)
console.info(`Status: ${statusMsg}`) console.info(`Status: ${statusMsg}`)
if (! this.dbReady) { if (! this.dbReady) {