Use `receiveTimeOut = 0` on SUB socket and rely on the retries from the `await().atMost()`. Also resubscribe in the retry callback before publishing the next attempt
Use `receiveTimeOut = 0` on SUB socket and rely on the retries from the `await().atMost()`. Also resubscribe in the retry callback before publishing the next attempt