diff --git a/src/Socket/messages-recv.ts b/src/Socket/messages-recv.ts index 02d0a584091..2d20654b29f 100644 --- a/src/Socket/messages-recv.ts +++ b/src/Socket/messages-recv.ts @@ -1578,7 +1578,10 @@ export const makeMessagesRecvSocket = (config: SocketConfig) => { }) ]) } finally { - await sendMessageAck(node).catch(ackErr => logger.error({ ackErr }, 'failed to ack notification')) + await sendMessageAck(node).catch(ackErr => { + logger.error({ ackErr }, 'failed to ack notification') + ws.close() + }) } }