Releases: sonus21/rqueue
Releases · sonus21/rqueue
Queue metrics
- Expose 6 queue metrics using micrometer. (queue-size, delay queue size, processing queue size, dead letter queue size, execution counter, failure counter)
- Fix an issue in scheduler that's getting scheduled at the delay of 5 seconds. [this leads to messages are not copied from delayed queue to main queue on high load.
- An api to move messages from dead letter queue to other queue (any source queue to target queue).
Rqueue
- A message can be delayed for an arbitrary period of time or delivered immediately.
- Multiple messages can be consumed in parallel by different workers.
- Message delivery: It's guaranteed that a message is consumed at least once. (Message would be consumed by a worker more than once due to the failure in the underlying worker/restart-process etc, otherwise exactly one delivery)