-
Notifications
You must be signed in to change notification settings - Fork 57
Installing & Using
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.
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.
See DynoShardSupplier and RedisQueues for a reference implementation that uses Dynomite host supplier to determine the shards.
Messages from the queue are polled only from the current shard, so it is required that you have at-least 1 server serving the queue per availability zone.