diff --git a/src/main/java/io/socket/client/Socket.java b/src/main/java/io/socket/client/Socket.java
index fe50c08..49bc378 100644
--- a/src/main/java/io/socket/client/Socket.java
+++ b/src/main/java/io/socket/client/Socket.java
@@ -334,6 +334,7 @@ public class Socket extends Emitter {
                 break;
 
             case Parser.CONNECT_ERROR:
+                this.destroy();
                 super.emit(EVENT_CONNECT_ERROR, packet.data);
                 break;
         }