diff options
| -rw-r--r-- | src/rabbit_variable_queue.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index ac2bab0fd7..ffdb695e40 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -289,10 +289,10 @@ ack(AckTags, State = #vqstate { index_state = IndexState }) -> purge(State = #vqstate { prefetcher = undefined, q4 = Q4, index_state = IndexState, len = Len }) -> {Q4Count, IndexState1} = remove_queue_entries(Q4, IndexState), - {TotalCount, State1} = + {Len, State1} = purge1(Q4Count, State #vqstate { index_state = IndexState1, q4 = queue:new() }), - {TotalCount, State1 #vqstate { len = 0 }}; + {Len, State1 #vqstate { len = 0 }}; purge(State) -> purge(drain_prefetcher(stop, State)). |