diff --git a/src/Socket/messages-recv.ts b/src/Socket/messages-recv.ts index b3bbc20..dc3119f 100644 --- a/src/Socket/messages-recv.ts +++ b/src/Socket/messages-recv.ts @@ -86,7 +86,8 @@ export const makeMessagesRecvSocket = (config: SocketConfig) => { { tag: 'retry', attrs: { - count: retryCount.toString(), id: node.attrs.id, + count: retryCount.toString(), + id: node.attrs.id, t: node.attrs.t, v: '1' } @@ -497,5 +498,5 @@ export const makeMessagesRecvSocket = (config: SocketConfig) => { } }) - return { ...sock, processMessage, sendMessageAck } + return { ...sock, processMessage, sendMessageAck, sendRetryRequest } }