diff --git a/lib/ddp-client.js b/lib/ddp-client.js index 4788632..c95336a 100644 --- a/lib/ddp-client.js +++ b/lib/ddp-client.js @@ -88,6 +88,10 @@ DDPClient.prototype._prepareHandlers = function() { }); self.socket.on("close", function(event) { + if (event.code === 1006) { + console.log('=> DDP connection was closed abnormally. Retrying...'); + } + self.emit("socket-close", event.code, event.reason); self._endPendingMethodCalls(); self._recoverNetworkError();