diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_variable_queue.erl | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index 225fc2ddaa..a63bda7045 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -637,6 +637,8 @@ ack(AckTags, State) -> persistent_count = PCount1, ack_out_counter = AckOutCount + length(AckTags) })}. +process_messages(_AckTags, undefined, State) -> + State; process_messages(AckTags, MsgFun, State = #vqstate{pending_ack = PA}) -> lists:foldl( fun(SeqId, State1) -> |