mongo-mqtt fixed dual methods

This commit is contained in:
Timo Volkmann 2020-07-24 12:06:05 +02:00
parent 7f903b9b73
commit bd0a913047

View File

@ -4,7 +4,7 @@ const _ = require('lodash')
const dbClient = new MongoClient("mongodb://garden:99009911@cloud.timovolkmann.de:27017/Smart_Garden", { useUnifiedTopology: true })
startMqttObserver()
// startMqttObserver()
export default async function startMqttObserver() {
console.log("setup connections...")
@ -15,7 +15,7 @@ export default async function startMqttObserver() {
const sensorData = db.collection('sensorData');
console.log("collection retrieved.")
// setup mqtt client
mqttClient = mqtt.connect('mqtt://mqtt.timovolkmann.de')
let mqttClient = mqtt.connect('mqtt://mqtt.timovolkmann.de')
mqttClient.on('connect', onMqttConnect(mqttClient))
mqttClient.on('message', messageCallback(sensorData))
})