diff --git a/lib/link/connectors.js b/lib/link/connectors.js
index 929786e3..01a9258e 100644
--- a/lib/link/connectors.js
+++ b/lib/link/connectors.js
@@ -260,11 +260,8 @@ class WebSocketClientConnector extends WebSocketBaseConnector {
 			this._lastReceivedSeq = null;
 			this._sessionToken = null;
 			this._sendBuffer.length = 0;
-			if (this._connected) {
-				this._connected = false;
-				this.emit("close");
-			}
-			this.emit("invalidate");
+			this._connected = false;
+			this.emit("close");
 			return;
 		}
 
@@ -290,16 +287,16 @@ class WebSocketClientConnector extends WebSocketBaseConnector {
 				this._sessionToken = null;
 				this._sendBuffer.length = 0;
 				this._state = "new";
-
-				if (this._connected) {
-					this._connected = false;
-					this.emit("close");
-				}
+				this._connected = false;
+				this.emit("close");
 
 			} else {
 				this._state = "handshake";
 				this.reconnect();
-				this.emit("drop");
+				if (this._connected) {
+					this._connected = false;
+					this.emit("drop");
+				}
 			}
 
 			this.stopHeartbeat();