diff options
| -rw-r--r-- | src/rabbit_variable_queue.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index 1434cd17c2..f3c73f49fc 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -537,7 +537,7 @@ delete_and_terminate(_Reason, State) -> %% part of 'purge' and 'purge_pending_ack', other than deleting %% it. That's why the last parameter to those functions is delete %% and terminate. - {_PurgeCount, State1} = purge(State), + State1 = purge_when_no_pending_acks(State), State2 = #vqstate { msg_store_clients = {MSCStateP, MSCStateT} } = purge_pending_ack(false, State1, true), case MSCStateP of |