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

changes

Browse Source
This commit is contained in:
Wolfgang Hottgenroth 2017-05-05 16:48:47 +02:00
parent 0c9468f3a5
commit 724f60354c
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/main.ts
View File

@ -3,6 +3,7 @@ import * as Mongo from 'mongodb'
import * as Queue from './queue' import * as Queue from './queue'
import * as MqttMessage from './mqtt_message' import * as MqttMessage from './mqtt_message'
var console = require('chalk-console') var console = require('chalk-console')
@ -40,7 +41,7 @@ Mongo.MongoClient.connect(options['database'],
dbHandle = tmpDbHandle dbHandle = tmpDbHandle
dbReady = true; dbReady = true;
console.info("Connected to database") console.info("Connected to database")
dbHandle.on('error', () => { console.warn("Error on database") }) dbHandle.on('reconnectFailed', (err : any) => { console.warn(`Error on database ${err}`) })
dbHandle.on('reconnect', () => { dbHandle.on('reconnect', () => {
console.info("Reconnect on database") console.info("Reconnect on database")
dbReady = true dbReady = true
@ -61,7 +62,7 @@ Mongo.MongoClient.connect(options['database'],
var queue = new Queue.Queue<MqttMessage.MqttMessage>() var queue = new Queue.Queue<MqttMessage.MqttMessage>()
queue.on('data', () => { queue.on('data', () => {
if (dbReady || true) { // FIXME if (dbReady) {
while (! queue.isEmpty()) { while (! queue.isEmpty()) {
var msg : MqttMessage.MqttMessage = queue.deq() var msg : MqttMessage.MqttMessage = queue.deq()
console.info(`Something in the queue: ${JSON.stringify(msg)}`) console.info(`Something in the queue: ${JSON.stringify(msg)}`)