From 478a69d834904f62cc4fb5ff52d5ed345e6859af Mon Sep 17 00:00:00 2001
From: Trygve Laugstøl <trygvis@inamo.no>
Date: Sun, 1 Nov 2015 16:13:45 +0100
Subject: web: o Publishing messages when the name/description is changed from
 the web.

---
 src/mqtt/DillerMqtt.js | 40 ----------------------------------------
 1 file changed, 40 deletions(-)
 delete mode 100644 src/mqtt/DillerMqtt.js

(limited to 'src/mqtt/DillerMqtt.js')

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;
-- 
cgit v1.2.3