diff --git a/lib/stratum.js b/lib/stratum.js
index bf92900..c0f922e 100644
--- a/lib/stratum.js
+++ b/lib/stratum.js
@@ -170,8 +170,11 @@ var StratumClient = function(options){
                         messageJson = JSON.parse(message);
                     } catch(e) {
                         _this.emit('malformedMessage', message);
+                        socket.end();
+                        return;
                     }
-                    
+
+
                     if (messageJson) {
                         handleMessage(messageJson);
                     }