Releases: Netflix/dyno-queues
Releases · Netflix/dyno-queues
Update Travis build status location
Release sans global properties from demo.properties
v2.0.21 Comment out Global properties from demo.properties
findStaleMessages() returns from all shards
Make findStaleMessages() return stale messages from all shards Note: All items returned MUST be checked at the app level if they've already been processed before acting on them (eg: removing them)
Add atomicRemove() and findStaleMessages()
Add findStaleMessages() API Attempts to return the items present in the local queue shard but not in the hashmap, if any. (Ideally, we would not require this function, however, in some configurations, especially with multi-region write traffic sharing the same queue, we may find ourselves with stale items in the queue shards)
Add atomicRemove() and findStaleMessages()
Add findStaleMessages() API Attempts to return the items present in the local queue shard but not in the hashmap, if any. (Ideally, we would not require this function, however, in some configurations, especially with multi-region write traffic sharing the same queue, we may find ourselves with stale items in the queue shards)
Make popMsgWithPredicateObeyPriority() check if hash exists
In some weird cases, we find the message in the queue but without a payload in the hashmap. Although this is never expected, it seems to happen, and this patch should stop the bleeding until we find out the root cause.
Make popMsgWithPredicateObeyPriority() check if hash exists
In some weird cases, we find the message in the queue but without a payload in the hashmap. Although this is never expected, it seems to happen, and this patch should stop the bleeding until we find out the root cause.
Make popMsgWithPredicateObeyPriority() check if hash exists
In some weird cases, we find the message in the queue but without a payload in the hashmap. Although this is never expected, it seems to happen, and this patch should stop the bleeding until we find out the root cause.
atomicProcessUnacks() and getAllMessages() w/ tests fixed
JedisMock cannot be cast to DynoJedisClient Tests fail without this fix.
atomicProcessUnacks() and getAllMessages() w/ tests fixed
JedisMock cannot be cast to DynoJedisClient Tests fail without this fix.