From b9f03e7d80983fcad64e90011cf84d013d410f2d Mon Sep 17 00:00:00 2001
From: Nick O'Leary <nick.oleary@gmail.com>
Date: Wed, 16 Mar 2016 11:15:30 +0000
Subject: [PATCH] Deprecate old mqtt client and connection pool modules

---
 nodes/core/io/lib/mqtt.js               | 3 +++
 nodes/core/io/lib/mqttConnectionPool.js | 6 ++++--
 2 files changed, 7 insertions(+), 2 deletions(-)

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();