diff --git a/nodes/core/io/lib/mqttConnectionPool.js b/nodes/core/io/lib/mqttConnectionPool.js
index b43498eed..ebd3dc672 100644
--- a/nodes/core/io/lib/mqttConnectionPool.js
+++ b/nodes/core/io/lib/mqttConnectionPool.js
@@ -74,7 +74,7 @@ module.exports = {
                         client.once(a,b);
                     },
                     connect: function() {
-                        if (!client.isConnected() && !connecting) {
+                        if (client && !client.isConnected() && !connecting) {
                             connecting = true;
                             client.connect(options);
                         }