diff options
Diffstat (limited to 'src/mqtt/DillerMqttClient.js')
-rw-r--r-- | src/mqtt/DillerMqttClient.js | 5 |
1 files changed, 4 insertions, 1 deletions
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/#'); + } }); } |