added retain options to mqtt publish

ROBOTEAM-HOME · Apr 4, 2017 · 434816d · 434816d
1 parent 4a91a36
commit 434816d
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/lib/mqtt_ascoltatore.js b/lib/mqtt_ascoltatore.js
@@ -134,7 +134,8 @@ MQTTAscoltatore.prototype.publish = function publish(topic, message, options, do
   this._raiseIfClosed();
 
   this._client.publish(this._pubTopic(topic), message, {
-    qos: (options && (options.qos !== undefined)) ? options.qos : 1
+    qos: (options && (options.qos !== undefined)) ? options.qos : 1,
+    retain: (options && (options.retain !== undefined)) ? options.retain : false
   }, function() {
     debug("new message published to " + topic);
     wrap(done)();