diff --git a/packages/controller/src/WsServerConnector.ts b/packages/controller/src/WsServerConnector.ts index 7277f8c3..439a2056 100644 --- a/packages/controller/src/WsServerConnector.ts +++ b/packages/controller/src/WsServerConnector.ts @@ -106,6 +106,9 @@ export default class WsServerConnector extends lib.WebSocketBaseConnector { this._state = "connected"; this._attachSocketHandlers(); this._dropSendBufferSeq(lastSeq); + logger.verbose( + `Connector | resuming session with ${this.dst}, resending ${this._sendBuffer.length} buffered messages` + ); for (let message of this._sendBuffer) { this._socket.send(JSON.stringify(message)); } @@ -113,7 +116,7 @@ export default class WsServerConnector extends lib.WebSocketBaseConnector { } _timedOut() { - logger.verbose("Connector | Connection timed out"); + logger.verbose(`Connector | Connection to ${this.dst} timed out`); this._close(); } diff --git a/packages/lib/src/link/connectors.ts b/packages/lib/src/link/connectors.ts index 8ce84f8f..d14b89e3 100644 --- a/packages/lib/src/link/connectors.ts +++ b/packages/lib/src/link/connectors.ts @@ -713,12 +713,14 @@ export abstract class WebSocketClientConnector extends WebSocketBaseConnector