Wake up all queues after policy change.
return to a simpler, better BQ:dropwhile, and introduce 'fetchwhile'
...to cover the remaining required functionality, including the
ability to process messages along the way, pass around an accumulator,
and get hold of the IsDelivered flag (not needed in our use case but
included for similarity with 'fetch').
remove unused state var
We were diligently maintaining ack_msg_id, but never actually using it
for anything. And it's always been like that.
merge default into bug25328
unbreak qc (hopefully)
merge default into bug25328
Whitespace
merge default
merge bug25321 into stable
move generic cross-node funs from rabbit_amqqueue to delegate
since the latter changes less frequently
get rid of last remaining cross-node fun in rabbit_amqqueue
There was no need for the rabbit_misc:with_exit_handler in
safe_delegate_call_ok, since the error condition caught be that is
also being caught by the check in 'filter'. Getting rid of the
superfluous check allows us to just invoke delegate:call and thus get
rid of the funs. Plus inline the lot.
Compare RabbitMQ versions ignoring the "patch" version (as semver.org calls it). Not that we are full on semver, but close enough.
add test for vq:fetchwhile
test more
yet more tests
Merged bug25328
remove pre-0-9-1 cruft
Merge bug25335
stable to default
Send messages immediately if we are not busy.