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

mongo again

Browse Source
This commit is contained in:
Wolfgang Hottgenroth
2017-08-27 23:48:06 +02:00
parent 6a364bd38a
commit 3211625b06
2 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
dist/main.js vendored
View File

@ -4,6 +4,7 @@ const log = require("./log");
const mqtt = require("./mqttdispatcher"); const mqtt = require("./mqttdispatcher");
const config = require("./config"); const config = require("./config");
const EspThermToJson = require("./espthermtojson"); const EspThermToJson = require("./espthermtojson");
const MongoSave = require("./mongosave");
const MissingEventDetector = require("./missingeventdetector"); const MissingEventDetector = require("./missingeventdetector");
log.info("Dispatcher starting"); log.info("Dispatcher starting");
config.readConfig(); config.readConfig();
@ -12,8 +13,8 @@ const ESP_THERM_TOPIC = 'IoT/espThermometer2/#';
dispatcher.register(ESP_THERM_TOPIC, 'toJson', EspThermToJson.espThermToJson); dispatcher.register(ESP_THERM_TOPIC, 'toJson', EspThermToJson.espThermToJson);
let missingeventdetector = new MissingEventDetector.MissingEventDetector(); let missingeventdetector = new MissingEventDetector.MissingEventDetector();
dispatcher.register(ESP_THERM_TOPIC, 'MissingEventDetector', missingeventdetector); dispatcher.register(ESP_THERM_TOPIC, 'MissingEventDetector', missingeventdetector);
// let mongo : MongoSave.MongoSave = new MongoSave.MongoSave(config.dict.mongoDbUrl) let mongo = new MongoSave.MongoSave(config.dict.mongoDbUrl);
// dispatcher.register(ESP_THERM_TOPIC, 'MongoSave', mongo); dispatcher.register(ESP_THERM_TOPIC, 'MongoSave', mongo);
dispatcher.exec(); dispatcher.exec();
log.info("Dispatcher running"); log.info("Dispatcher running");
//# sourceMappingURL=main.js.map //# sourceMappingURL=main.js.map

4
src/main.ts
View File

@ -24,8 +24,8 @@ let missingeventdetector : MissingEventDetector.MissingEventDetector =
new MissingEventDetector.MissingEventDetector() new MissingEventDetector.MissingEventDetector()
dispatcher.register(ESP_THERM_TOPIC, 'MissingEventDetector', missingeventdetector) dispatcher.register(ESP_THERM_TOPIC, 'MissingEventDetector', missingeventdetector)
// let mongo : MongoSave.MongoSave = new MongoSave.MongoSave(config.dict.mongoDbUrl) let mongo : MongoSave.MongoSave = new MongoSave.MongoSave(config.dict.mongoDbUrl)
// dispatcher.register(ESP_THERM_TOPIC, 'MongoSave', mongo); dispatcher.register(ESP_THERM_TOPIC, 'MongoSave', mongo);
dispatcher.exec() dispatcher.exec()