Releases: Netflix/dyno-queues
Releases · Netflix/dyno-queues
atomicProcessUnacks() and getAllMessages()
v2.0.17 Add atomicProcessUnacks() and getAllMessages()
Fix null return from popMsgWithPredicateObeyPriority
v2.0.16-rc2 Fix null return from popMsgWithPredicateObeyPriority
Make popWithMsgPredicate() obey queue priority
Previously popWithMsgPredicate() would pop the first item it found in the hashmap that matches the given predicate. With this patch, it will obey the queueing priority.
Fix casting for bulk pop
v2.0.15-rc2 atomicBulkPopHelper() should cast to Message before returning
Add unsafeBulkPop() and localGet()
unsafeBulkPop() allows bulk popping from all shards. loaclGet() does a get() with a non quorum connection. TODO: unsafeBulkPop() will return nil if messageCount > size(). Fix this. TODO 2: Do code cleanup.
Add atomic bulkPop() API
Add a atomic bulkPop() API Using queues with DC_EACH_SAFE_QUORUM is quite expensive. The bulk pop operation is meant to pop more within a single round trip.
Add popMsgWithPredicate() API
- Also less log spam for unsafePop*() functions.
Update dyno dependency to dyno-1.7.2-rc2
v2.0.12-rc2 Pin to dyno-1.7.2-rc2
Update dyno dependency to dyno-1.7.2
- Dyno now has the ability to have nonQuorumConn use DC_ONE with Dynomite, rather than talking directly to Redis.
popWithMsgId() and unsafePopWithMsgId() should report metrics
v2.0.11-rc6 popWithMsgId() and unsafePopWithMsgId() should report metrics