Skip to content

Add unsafeBulkPop() and localGet()

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