The GitHub Actions job "Golang Coverage" on 
rocketmq-clients.git/fix_process_queue has failed.
Run started by GitHub user guyinyou (triggered by guyinyou).

Head commit for run:
59eb18199fca9d9bb7686ff68e30f3af2bb56b2a / guyinyou 
<[email protected]>
[Go] Fix missing return after retry scheduling in process_queue

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).

Report URL: https://github.com/apache/rocketmq-clients/actions/runs/27326824053

With regards,
GitHub Actions via GitBox

Reply via email to