Skip to content

Releases: sonus21/rqueue

Queue metrics

11 Dec 15:50

Choose a tag to compare

  1. Expose 6 queue metrics using micrometer. (queue-size, delay queue size, processing queue size, dead letter queue size, execution counter, failure counter)
  2. 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.
  3. An api to move messages from dead letter queue to other queue (any source queue to target queue).

Rqueue

18 Nov 06:17
3d818f3

Choose a tag to compare

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