diff --git a/lib/ddp-client.js b/lib/ddp-client.js
index 7e65c10..252ea8b 100644
--- a/lib/ddp-client.js
+++ b/lib/ddp-client.js
@@ -146,6 +146,8 @@ DDPClient.prototype._message = function(data) {
 
   } else if (data.msg === "connected") {
     self.session = data.session;
+    self._isConnecting = false;
+    self._isReconnecting = false;
     self.emit("connected");
 
   // method result