diff --git a/nodes/io/lib/mqttConnectionPool.js b/nodes/io/lib/mqttConnectionPool.js
index bb0346490..6281a2cab 100644
--- a/nodes/io/lib/mqttConnectionPool.js
+++ b/nodes/io/lib/mqttConnectionPool.js
@@ -30,6 +30,7 @@ module.exports = {
         if (!connections[id]) {
             connections[id] = function() {
                 var client = mqtt.createClient(port,broker);
+                client.setMaxListeners(0);
                 var options = {keepalive:15,clientId:'mqtt_' + (1+Math.random()*4294967295).toString(16)};
                 var queue = [];
                 var subscriptions = [];