diff options
| author | Diana Corbacho <diana@rabbitmq.com> | 2019-04-10 17:32:08 +0100 |
|---|---|---|
| committer | Diana Corbacho <diana@rabbitmq.com> | 2019-04-10 17:32:08 +0100 |
| commit | 1c182e755f35b0b65a9137cb9d0c4ea027d01e97 (patch) | |
| tree | 744a9ab3adc1b685da541c983b5c9ac0aff3c20f /src | |
| parent | 6d931d531567e4d51e3606ae8b5e2c35e9a59e05 (diff) | |
| download | rabbitmq-server-git-1c182e755f35b0b65a9137cb9d0c4ea027d01e97.tar.gz | |
Reset in-memory counts after purging
[#164735591]
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_fifo.erl | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/src/rabbit_fifo.erl b/src/rabbit_fifo.erl index 274a196bc7..f8f4e78943 100644 --- a/src/rabbit_fifo.erl +++ b/src/rabbit_fifo.erl @@ -126,7 +126,7 @@ init(#{name := Name, queue_resource := Resource} = Conf) -> update_config(Conf, #?MODULE{cfg = #cfg{name = Name, - resource = Resource}}). + resource = Resource}}). update_config(Conf, State) -> DLH = maps:get(dead_letter_handler, Conf, undefined), @@ -317,7 +317,9 @@ apply(#{index := RaftIdx}, #purge{}, returns = lqueue:new(), msg_bytes_enqueue = 0, prefix_msgs = {[], []}, - low_msg_num = undefined}, + low_msg_num = undefined, + msg_bytes_in_memory = 0, + msgs_ready_in_memory = 0}, []), %% as we're not checking out after a purge (no point) we have to %% reverse the effects ourselves |