The GitHub Actions job "Build" on 
rocketmq-clients.git/fix/rust-push-consumer-delivery-attempt has failed.
Run started by GitHub user leizhiyuan (triggered by leizhiyuan).

Head commit for run:
b6e345a9e0c55f10580cdd2308f0648df3fa5ee6 / leizhiyuann <[email protected]>
[ISSUE #1413] [Rust] Increase delivery attempt on FIFO local retry

FifoConsumerWorker kept the attempt in a local counter, so the listener saw
the server-provided delivery attempt on every local retry, the first retry
used the delay of attempt 2, and the DLQ request reported max attempts + 1.

Align with the Java client (ProcessQueueImpl#eraseFifoMessage): while the
delivery attempt is below the max attempts, take the delay of the current
attempt, increase the attempt on the MessageView
(MessageViewImpl#incrementAndGetDeliveryAttempt) and consume again;
otherwise forward the message to the DLQ with its current delivery
attempt. The listener now sees 1, 2, ..., max attempts. The standard
(non-FIFO) path is unchanged.

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

With regards,
GitHub Actions via GitBox

Reply via email to