Installing & Using

Pre-requisites

dyno-queues are built on top of Dynomite so a cluster needs to be installed / provisioned. In a distributed environment, we rely on the DC_QUORUM_SAFE consistency offered by dynomite to ensure the writes are done with full DC quorum.

Configuring Queues

Queues are sharded based on the availability zone. When pushing an element to the queue, the shard is determined based on round robin. This will ensure eventually all the shards are balanced. When configuring the queues, ShardSupplier determines the number of available shards and current shard.
Messages are polled only from the current shard. So it is required that you have at-least 1 server serving the queue per availability zone.