hitlk opened a new issue, #208: URL: https://github.com/apache/rocketmq-mqtt/issues/208
https://github.com/apache/rocketmq-mqtt/blob/971fee8410b0a8426a34d9e6d6e38da1bf858438/mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/infly/RetryDriver.java#L226-L248 这段代码中，如果当前订阅为非重试订阅且未达到`getSizeOfNotRollWhenAckSlow`阈值，则会调用`rollNextNoWaitRetry`函数，该函数里又会滚动到下个待发送消息，这就会导致下个消息比当前消息先发送，该逻辑是否有问题，或者我理解的不对，还请指正。 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
