diff --git a/nodes/core/io/lib/mqtt.js b/nodes/core/io/lib/mqtt.js index 544a84f02..d2f3a6761 100644 --- a/nodes/core/io/lib/mqtt.js +++ b/nodes/core/io/lib/mqtt.js @@ -16,6 +16,9 @@ var util = require("util"); var mqtt = require("mqtt"); var events = require("events"); + +util.log("[warn] nodes/core/io/lib/mqtt.js is deprecated and will be removed in a future release of Node-RED. Please report this usage to the Node-RED mailing list."); + //var inspect = require("util").inspect; //var Client = module.exports.Client = function( diff --git a/nodes/core/io/lib/mqttConnectionPool.js b/nodes/core/io/lib/mqttConnectionPool.js index 0a2410ad1..c1dde522a 100644 --- a/nodes/core/io/lib/mqttConnectionPool.js +++ b/nodes/core/io/lib/mqttConnectionPool.js @@ -17,6 +17,8 @@ var util = require("util"); var mqtt = require("./mqtt"); var settings = require(process.env.NODE_RED_HOME+"/red/red").settings; +util.log("[warn] nodes/core/io/lib/mqttConnectionPool.js is deprecated and will be removed in a future release of Node-RED. Please report this usage to the Node-RED mailing list."); + var connections = {}; function matchTopic(ts,t) { @@ -60,7 +62,7 @@ module.exports = { subscribe: function(topic,qos,callback,ref) { ref = ref||0; subscriptions[topic] = subscriptions[topic]||{}; - + var sub = { topic:topic, qos:qos, @@ -104,7 +106,7 @@ module.exports = { } }, disconnect: function(ref) { - + this._instances -= 1; if (this._instances == 0) { client.disconnect();