Lazy Susan is a Redis-based multi-tenant FIFO queue.
Lazy Susan works with either a single Redis node or a Redis cluster. Simply use the corresponding com.nosto.redis.queue.MultitenantQueue constructor, depending on which Redis configuration you wish to use.
Call com.nosto.redis.queue.MultitenantQueue.enqueue to enqueue a message.
The dequeue interval parameter specifies the rate at which the tenant's messages are dequeued. For example, a dequeueInterval of Duration.ofMillis(5) means that 1 message can be dequeued every 5 milliseconds.
The dequeue interval is set on a per-tenant basis and the value overwrites the value used to enqueue previous messages for the same tenant.
If a message with the same key already exists in the queue, the newly enqueued message overwrites the previously enqueued message and com.nosto.redis.queue.EnqueueResult.DUPLICATE_OVERWRITTEN is returned.
Call com.nosto.redis.queue.MultitenantQueue.dequeue to deqeue messages.
The messageInvisibilityPeriod parameter is used to mark each dequeued message as invisible. Invisible messages cannot be dequeued until messageInvisibilityPeriod ellapses. Invisible messages can be deleted by calling com.nosto.redis.queue.MultitenantQueue.delete.
Call com.nosto.redis.queue.MultitenantQueue.peek to fetch a message from a queue without marking it as invisible.
The number messages, broken down by tenant, can be queried for a queue by calling com.nosto.redis.queue.MultitenantQueue.getStatistics.
A queue can be purged by calling com.nosto.redis.queue.MultitenantQueue.purge.