From dda9ef2ae7971bceaa792e328c8489cb0695b77e Mon Sep 17 00:00:00 2001
From: Trygve Laugstøl <trygvis@inamo.no>
Date: Mon, 16 Nov 2015 18:46:56 +0100
Subject: 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.

---
 src/mqtt/DillerMqttClient.js | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

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

diff --git a/src/mqtt/DillerMqttClient.js b/src/mqtt/DillerMqttClient.js
index 62f5aef..b9cf01b 100644
--- a/src/mqtt/DillerMqttClient.js
+++ b/src/mqtt/DillerMqttClient.js
@@ -12,7 +12,7 @@ function DillerMqttClient(config, tx) {
   var mqttClient;
   var hostname = os.hostname();
 
-  function run(clientType) {
+  function run(clientType, subscribeToLog) {
     if (mqttClient) {
       throw 'Already connected';
     }
@@ -36,6 +36,9 @@ function DillerMqttClient(config, tx) {
     mqttClient.on('connect', function () {
       log.info('Connected');
       mqttClient.subscribe('/diller/#');
+      if (subscribeToLog) {
+        mqttClient.subscribe('$SYS/broker/log/#');
+      }
     });
   }
 
-- 
cgit v1.2.3