EventHorizon.RocketMQ.Remoting 0.3.1
·
14 commits
to main
since this release
Fixes
- Aligns Broker-assigned classic POP terminal retry handling with Apache RocketMQ Java: after MaxDeliveryAttempts, retry uses message age to select the next POP invisibility delay and ACKs only after the age exceeds the four-hour terminal threshold.
- Prevents normal POP retries at the delivery limit from being implicitly forwarded to the dead-letter queue. Explicit ConsumeResult.DeadLetter and negative delay requests remain supported.
- Documents clustering retry-topic behavior: the consumer automatically subscribes to %RETRY%{consumerGroup}, advertises it in heartbeats, and consumes Broker assignments in PULL mode.
- Expands unit and live Broker coverage for age-based retry, terminal ACK, and the absence of reject/send-back operations.
NuGet: https://www.nuget.org/packages/EventHorizon.RocketMQ.Remoting/0.3.1