diff --git a/exec/mqtt_stats.js b/exec/mqtt_stats.js index aa62ee83d2497e3c79ea72cb515f651063af6719..2a0b5473d1ace10bf58e1564e66767d705f31fcf 100644 --- a/exec/mqtt_stats.js +++ b/exec/mqtt_stats.js @@ -5,6 +5,7 @@ var mqtt = new MQTT; var topic = "sbbs/" + system.qwk_id + "/stats"; var retain = true; +var qos = 1; if(!mqtt.connect()) { alert(format("Error (%s) connecting to %s:%u" @@ -13,13 +14,13 @@ if(!mqtt.connect()) { } if(argv.indexOf("-json") >= 0) { - if(!mqtt.publish(retain, topic, JSON.stringify(system.stats))) { + if(!mqtt.publish(retain, qos, topic, JSON.stringify(system.stats))) { alert(format("Error (%s) publishing to %s", mqtt.error_str, topic)); exit(1); } } else { for(var p in system.stats) { - if(!mqtt.publish(retain, topic + "/" + p, JSON.stringify(system.stats[p]))) { + if(!mqtt.publish(retain, qos, topic + "/" + p, system.stats[p])) { alert(format("Error (%s) publishing to %s", mqtt.error_str, topic)); exit(1); }