diff --git a/packages/node_modules/@node-red/nodes/core/function/90-exec.js b/packages/node_modules/@node-red/nodes/core/function/90-exec.js
index 02a908d4b..beb4d11d4 100644
--- a/packages/node_modules/@node-red/nodes/core/function/90-exec.js
+++ b/packages/node_modules/@node-red/nodes/core/function/90-exec.js
@@ -105,18 +105,26 @@ module.exports = function(RED) {
                     }
                     node.activeProcesses[child.pid] = child;
                     child.stdout.on('data', function (data) {
-                        if (node.activeProcesses.hasOwnProperty(child.pid) && node.activeProcesses[child.pid] !== null) {
-                            // console.log('[exec] stdout: ' + data,child.pid);
-                            if (isUtf8(data)) { msg.payload = data.toString(); }
-                            else { msg.payload = data; }
-                            nodeSend([RED.util.cloneMessage(msg),null,null]);
+                        try {
+                            if (node.activeProcesses.hasOwnProperty(child.pid) && node.activeProcesses[child.pid] !== null) {
+                                // console.log('[exec] stdout: ' + data,child.pid);
+                                if (isUtf8(data)) { msg.payload = data.toString(); }
+                                else { msg.payload = data; }
+                                nodeSend([RED.util.cloneMessage(msg),null,null]);
+                            }
+                        } catch (err) {
+                            node.error(err.toString());
                         }
                     });
                     child.stderr.on('data', function (data) {
-                        if (node.activeProcesses.hasOwnProperty(child.pid) && node.activeProcesses[child.pid] !== null) {
-                            if (isUtf8(data)) { msg.payload = data.toString(); }
-                            else { msg.payload = data; }
-                            nodeSend([null,RED.util.cloneMessage(msg),null]);
+                        try {
+                            if (node.activeProcesses.hasOwnProperty(child.pid) && node.activeProcesses[child.pid] !== null) {
+                                if (isUtf8(data)) { msg.payload = data.toString(); }
+                                else { msg.payload = data; }
+                                nodeSend([null,RED.util.cloneMessage(msg),null]);
+                            }
+                        } catch (err) {
+                            node.error(err.toString());
                         }
                     });
                     child.on('close', function (code,signal) {
diff --git a/packages/node_modules/@node-red/nodes/core/network/10-mqtt.js b/packages/node_modules/@node-red/nodes/core/network/10-mqtt.js
index 451035a74..3600b016b 100644
--- a/packages/node_modules/@node-red/nodes/core/network/10-mqtt.js
+++ b/packages/node_modules/@node-red/nodes/core/network/10-mqtt.js
@@ -227,6 +227,7 @@ module.exports = function(RED) {
      * Handle the payload / packet recieved in MQTT In and MQTT Sub nodes
      */
     function subscriptionHandler(node, datatype ,topic, payload, packet) {
+        if (!packet) { packet = {}; }
         const msg = {topic:topic, payload:null, qos:packet.qos, retain:packet.retain};
         const v5 = (node && node.brokerConn)
             ? node.brokerConn.v5()
@@ -1074,12 +1075,16 @@ module.exports = function(RED) {
 
                 if (!subscription.handler) {
                     subscription.handler = function (mtopic, mpayload, mpacket) {
-                        const sops = subscription.options ? subscription.options.properties : {}
-                        const pops = mpacket.properties || {}
-                        if (subIdsAvailable && pops.subscriptionIdentifier && sops.subscriptionIdentifier && (pops.subscriptionIdentifier !== sops.subscriptionIdentifier)) {
-                            //do nothing as subscriptionIdentifier does not match
-                        } else if (matchTopic(topic, mtopic)) {
-                            subscription.callback && subscription.callback(mtopic, mpayload, mpacket)
+                        try {
+                            const sops = subscription.options ? subscription.options.properties : {}
+                            const pops = (mpacket && mpacket.properties) || {}
+                            if (subIdsAvailable && pops.subscriptionIdentifier && sops.subscriptionIdentifier && (pops.subscriptionIdentifier !== sops.subscriptionIdentifier)) {
+                                //do nothing as subscriptionIdentifier does not match
+                            } else if (matchTopic(topic, mtopic)) {
+                                subscription.callback && subscription.callback(mtopic, mpayload, mpacket)
+                            }
+                        } catch (err) {
+                            node.error("MQTT subscription handler error: " + err.toString());
                         }
                     }
                 }
diff --git a/packages/node_modules/@node-red/nodes/core/network/22-websocket.js b/packages/node_modules/@node-red/nodes/core/network/22-websocket.js
index f30fd91ce..3c877dc79 100644
--- a/packages/node_modules/@node-red/nodes/core/network/22-websocket.js
+++ b/packages/node_modules/@node-red/nodes/core/network/22-websocket.js
@@ -297,7 +297,11 @@ module.exports = function(RED) {
         }
         msg._session = {type:"websocket",id:id};
         for (var i = 0; i < this._inputNodes.length; i++) {
-            this._inputNodes[i].send(msg);
+            try {
+                this._inputNodes[i].send(msg);
+            } catch (err) {
+                this.error(RED._("websocket.errors.send-error") + " " + err.toString());
+            }
         }
     }
 
diff --git a/packages/node_modules/@node-red/nodes/core/network/31-tcpin.js b/packages/node_modules/@node-red/nodes/core/network/31-tcpin.js
index 500bbe2c2..9c4ce13c6 100644
--- a/packages/node_modules/@node-red/nodes/core/network/31-tcpin.js
+++ b/packages/node_modules/@node-red/nodes/core/network/31-tcpin.js
@@ -127,32 +127,36 @@ module.exports = function(RED) {
                 connectionPool[id] = client;
 
                 client.on('data', function (data) {
-                    if (node.datatype != 'buffer') {
-                        data = data.toString(node.datatype);
-                    }
-                    if (node.stream) {
-                        var msg;
-                        if ((node.datatype) === "utf8" && node.newline !== "") {
-                            buffer = buffer+data;
-                            var parts = buffer.split(node.newline);
-                            for (var i = 0; i<parts.length-1; i+=1) {
-                                msg = {topic:node.topic, payload:parts[i]};
-                                if (node.trim == true) { msg.payload += node.newline; }
+                    try {
+                        if (node.datatype != 'buffer') {
+                            data = data.toString(node.datatype);
+                        }
+                        if (node.stream) {
+                            var msg;
+                            if ((node.datatype) === "utf8" && node.newline !== "") {
+                                buffer = buffer+data;
+                                var parts = buffer.split(node.newline);
+                                for (var i = 0; i<parts.length-1; i+=1) {
+                                    msg = {topic:node.topic, payload:parts[i]};
+                                    if (node.trim == true) { msg.payload += node.newline; }
+                                    msg._session = {type:"tcp",id:id};
+                                    node.send(msg);
+                                }
+                                buffer = parts[parts.length-1];
+                            } else {
+                                msg = {topic:node.topic, payload:data};
                                 msg._session = {type:"tcp",id:id};
                                 node.send(msg);
                             }
-                            buffer = parts[parts.length-1];
                         } else {
-                            msg = {topic:node.topic, payload:data};
-                            msg._session = {type:"tcp",id:id};
-                            node.send(msg);
-                        }
-                    } else {
-                        if ((typeof data) === "string") {
-                            buffer = buffer+data;
-                        } else {
-                            buffer = Buffer.concat([buffer,data],buffer.length+data.length);
+                            if ((typeof data) === "string") {
+                                buffer = buffer+data;
+                            } else {
+                                buffer = Buffer.concat([buffer,data],buffer.length+data.length);
+                            }
                         }
+                    } catch (err) {
+                        node.error(RED._("tcpin.errors.error",{error:err.toString()}));
                     }
                 });
                 client.on('end', function() {
@@ -222,35 +226,39 @@ module.exports = function(RED) {
 
                 var buffer = (node.datatype == 'buffer') ? Buffer.alloc(0) : "";
                 socket.on('data', function (data) {
-                    if (node.datatype != 'buffer') {
-                        data = data.toString(node.datatype);
-                    }
-                    if (node.stream) {
-                        var msg;
-                        if ((typeof data) === "string" && node.newline !== "") {
-                            buffer = buffer+data;
-                            var parts = buffer.split(node.newline);
-                            for (var i = 0; i<parts.length-1; i+=1) {
-                                msg = {topic:node.topic, payload:parts[i], ip:socket.remoteAddress, port:socket.remotePort};
-                                if (node.trim == true) { msg.payload += node.newline; }
+                    try {
+                        if (node.datatype != 'buffer') {
+                            data = data.toString(node.datatype);
+                        }
+                        if (node.stream) {
+                            var msg;
+                            if ((typeof data) === "string" && node.newline !== "") {
+                                buffer = buffer+data;
+                                var parts = buffer.split(node.newline);
+                                for (var i = 0; i<parts.length-1; i+=1) {
+                                    msg = {topic:node.topic, payload:parts[i], ip:socket.remoteAddress, port:socket.remotePort};
+                                    if (node.trim == true) { msg.payload += node.newline; }
+                                    msg._session = {type:"tcp",id:id};
+                                    node.send(msg);
+                                }
+                                buffer = parts[parts.length-1];
+                            } else {
+                                msg = {topic:node.topic, payload:data, ip:socket.remoteAddress, port:socket.remotePort};
                                 msg._session = {type:"tcp",id:id};
                                 node.send(msg);
                             }
-                            buffer = parts[parts.length-1];
-                        } else {
-                            msg = {topic:node.topic, payload:data, ip:socket.remoteAddress, port:socket.remotePort};
-                            msg._session = {type:"tcp",id:id};
-                            node.send(msg);
                         }
-                    }
-                    else {
-                        if ((typeof data) === "string") {
-                            buffer = buffer+data;
-                        } else {
-                            buffer = Buffer.concat([buffer,data],buffer.length+data.length);
+                        else {
+                            if ((typeof data) === "string") {
+                                buffer = buffer+data;
+                            } else {
+                                buffer = Buffer.concat([buffer,data],buffer.length+data.length);
+                            }
+                            fromi = socket.remoteAddress;
+                            fromp = socket.remotePort;
                         }
-                        fromi = socket.remoteAddress;
-                        fromp = socket.remotePort;
+                    } catch (err) {
+                        node.error(RED._("tcpin.errors.error",{error:err.toString()}));
                     }
                 });
                 socket.on('end', function() {
@@ -678,6 +686,7 @@ module.exports = function(RED) {
                 }
                 var chunk = "";
                 clients[connection_id].client.on('data', function(data) {
+                    try {
                     if (node.out === "sit") { // if we are staying connected just send the buffer
                         if (clients[connection_id]) {
                             const msg = clients[connection_id].lastMsg || {};
@@ -790,6 +799,9 @@ module.exports = function(RED) {
                             }
                         }
                     }
+                    } catch (err) {
+                        node.error(RED._("tcpin.errors.error",{error:err.toString()}));
+                    }
                 });
 
                 clients[connection_id].client.on('end', function() {
diff --git a/packages/node_modules/@node-red/nodes/core/network/32-udp.js b/packages/node_modules/@node-red/nodes/core/network/32-udp.js
index d42d3a7c3..27709c2bd 100644
--- a/packages/node_modules/@node-red/nodes/core/network/32-udp.js
+++ b/packages/node_modules/@node-red/nodes/core/network/32-udp.js
@@ -98,15 +98,19 @@ module.exports = function(RED) {
         });
 
         server.on('message', function (message, remote) {
-            var msg;
-            if (node.datatype =="base64") {
-                msg = { payload:message.toString('base64'), fromip:remote.address+':'+remote.port, ip:remote.address, port:remote.port };
-            } else if (node.datatype =="utf8") {
-                msg = { payload:message.toString('utf8'), fromip:remote.address+':'+remote.port, ip:remote.address, port:remote.port };
-            } else {
-                msg = { payload:message, fromip:remote.address+':'+remote.port, ip:remote.address, port:remote.port };
+            try {
+                var msg;
+                if (node.datatype =="base64") {
+                    msg = { payload:message.toString('base64'), fromip:remote.address+':'+remote.port, ip:remote.address, port:remote.port };
+                } else if (node.datatype =="utf8") {
+                    msg = { payload:message.toString('utf8'), fromip:remote.address+':'+remote.port, ip:remote.address, port:remote.port };
+                } else {
+                    msg = { payload:message, fromip:remote.address+':'+remote.port, ip:remote.address, port:remote.port };
+                }
+                node.send(msg);
+            } catch (err) {
+                node.error(RED._("udp.errors.error",{error:err.toString()}));
             }
-            node.send(msg);
         });
 
         server.on('listening', function () {