diff options
author | Trygve Laugstøl <trygvis@inamo.no> | 2015-11-16 18:46:56 +0100 |
---|---|---|
committer | Trygve Laugstøl <trygvis@inamo.no> | 2015-11-16 18:46:56 +0100 |
commit | dda9ef2ae7971bceaa792e328c8489cb0695b77e (patch) | |
tree | f4ce29c170dbd4af136418949a857eb9e89154ca /diller-mqtt.js | |
parent | f17922bcafe1f2f369c9be0f236570771c8ab214 (diff) | |
download | diller-server-dda9ef2ae7971bceaa792e328c8489cb0695b77e.tar.gz diller-server-dda9ef2ae7971bceaa792e328c8489cb0695b77e.tar.bz2 diller-server-dda9ef2ae7971bceaa792e328c8489cb0695b77e.tar.xz diller-server-dda9ef2ae7971bceaa792e328c8489cb0695b77e.zip |
core:
o Adding device_status table containing the latest device status.
mqtt:
o Listening on $SYS/broker/log, parse out messages about clients connecting and disconnecting and store in database.
Diffstat (limited to 'diller-mqtt.js')
-rw-r--r-- | diller-mqtt.js | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/diller-mqtt.js b/diller-mqtt.js index e528bb4..eb3c7f2 100644 --- a/diller-mqtt.js +++ b/diller-mqtt.js @@ -13,7 +13,7 @@ var tx = injector.get(require('./src/DillerTx')); * @type DillerMqttClient */ var dillerMqttClient = injector.get(require('./src/mqtt/DillerMqttClient')); -dillerMqttClient.run('mqtt'); +dillerMqttClient.run('mqtt', true); dillerMqttClient.on('message', function (topic, message, payload) { tx(function (pg, dao, diller) { |