Unfortunately you would have to externalize the queue somewhere, like we do with the ackedReceiveBuffer in the remote transport EndpointReader. That's not so pretty either. It's tricky.