guyinyou opened a new pull request, #1265: URL: https://github.com/apache/rocketmq-clients/pull/1265
In ackMessage0, changeInvisibleDuration, and forwardToDeadLetterQueue0, when the response code is not OK, the *Later() retry function is called but execution falls through to callback(nil), causing the message to be prematurely evicted from cache before the operation actually succeeds. This can lead to message loss. Add return statements after each *Later() call to prevent fallthrough, matching the Java implementation's behavior where the future is only resolved on terminal states (success or abandoned). -- 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]
