diff options
| -rw-r--r-- | src/rabbit_variable_queue.erl | 8 |
1 files changed, 3 insertions, 5 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index af91785b4a..a3b0ee720b 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -1397,7 +1397,9 @@ remove_queue_entries1( process_delivers_and_acks_fun(deliver_and_ack) -> fun (Delivers, Acks, State = #vqstate { index_state = IndexState }) -> - IndexState1 = qi_deliver_and_ack(Delivers, Acks, IndexState), + IndexState1 = + rabbit_queue_index:ack( + Acks, rabbit_queue_index:deliver(Delivers, IndexState)), State #vqstate { index_state = IndexState1 } end; process_delivers_and_acks_fun(_) -> @@ -1405,10 +1407,6 @@ process_delivers_and_acks_fun(_) -> State end. -qi_deliver_and_ack(Delivers, Acks, IndexState) -> - rabbit_queue_index:ack( - Acks, rabbit_queue_index:deliver(Delivers, IndexState)). - %%---------------------------------------------------------------------------- %% Internal gubbins for publishing %%---------------------------------------------------------------------------- |