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 /diller-mqtt.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 'diller-mqtt.js')
-rw-r--r-- | diller-mqtt.js | 18 |
1 files changed, 16 insertions, 2 deletions
diff --git a/diller-mqtt.js b/diller-mqtt.js index db6fc2b..e528bb4 100644 --- a/diller-mqtt.js +++ b/diller-mqtt.js @@ -4,5 +4,19 @@ var injector = new di.Injector(); var config = injector.get(require('./src/DillerConfig')); config.configureLogging('mqtt'); -var dillerMqtt = injector.get(require('./src/mqtt/DillerMqtt')); -dillerMqtt.run(); +/** + * @type {function(function(PgTx, DillerDao, Diller))} tx + */ +var tx = injector.get(require('./src/DillerTx')); + +/** + * @type DillerMqttClient + */ +var dillerMqttClient = injector.get(require('./src/mqtt/DillerMqttClient')); +dillerMqttClient.run('mqtt'); + +dillerMqttClient.on('message', function (topic, message, payload) { + tx(function (pg, dao, diller) { + return diller.onMessage(topic, message, payload); + }); +}); |