Skip to content

Add atomicRemove() and findStaleMessages()

Compare
Choose a tag to compare
@smukil smukil released this 23 Jan 22:17
· 14 commits to dev since this release
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)