diff options
author | Trygve Laugstøl <trygvis@inamo.no> | 2015-11-01 16:13:45 +0100 |
---|---|---|
committer | Trygve Laugstøl <trygvis@inamo.no> | 2015-11-01 16:13:45 +0100 |
commit | 478a69d834904f62cc4fb5ff52d5ed345e6859af (patch) | |
tree | efa4839e878f1debf3db6a11f0636405538af761 /src/mqtt/DillerMqtt.js | |
parent | 85474565b0a0d92a09fecb14e8bc0afaad7fbc64 (diff) | |
download | diller-server-478a69d834904f62cc4fb5ff52d5ed345e6859af.tar.gz diller-server-478a69d834904f62cc4fb5ff52d5ed345e6859af.tar.bz2 diller-server-478a69d834904f62cc4fb5ff52d5ed345e6859af.tar.xz diller-server-478a69d834904f62cc4fb5ff52d5ed345e6859af.zip |
web:
o Publishing messages when the name/description is changed from the web.
Diffstat (limited to 'src/mqtt/DillerMqtt.js')
-rw-r--r-- | src/mqtt/DillerMqtt.js | 40 |
1 files changed, 0 insertions, 40 deletions
diff --git a/src/mqtt/DillerMqtt.js b/src/mqtt/DillerMqtt.js deleted file mode 100644 index 0bd8ed9..0000000 --- a/src/mqtt/DillerMqtt.js +++ /dev/null @@ -1,40 +0,0 @@ -var di = require('di'); -var mqtt = require('mqtt'); - -function DillerMqtt(config, tx) { - var log = config.log(); - - function run() { - log.info('Connecting to ' + config.mqttUrl); - var mqttClient = mqtt.connect(config.mqttUrl); - - mqttClient.on('offline', function () { - log.info('offline'); - }); - - mqttClient.on('error', function (error) { - log.info('error', {error: error}); - }); - - mqttClient.on('connect', function () { - log.info('Connected'); - mqttClient.subscribe('/diller/#'); - }); - - mqttClient.on('message', function (topic, message, payload) { - tx(function (pg, dao, diller) { - return diller.onMessage(topic, message, payload); - }); - }); - } - - return { - run: run - }; -} -var _DillerTx = require('../DillerTx'); -var _DillerConfig = require('../DillerConfig'); - -di.annotate(DillerMqtt, new di.Inject(_DillerConfig, _DillerTx)); - -module.exports = DillerMqtt; |