diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2014-07-28 14:00:47 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2014-07-28 14:00:47 +0100 |
| commit | 3fcd2b90cade09d9906b2b656570a767be5ba206 (patch) | |
| tree | 6c74e6a251afd9c30bc30c50005be4c542b2eba2 | |
| parent | 95b7cce4bee12d5db53874c5fd54ce3ea4c19a3d (diff) | |
| download | rabbitmq-server-3fcd2b90cade09d9906b2b656570a767be5ba206.tar.gz | |
Oops!
| -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 1465e884..bfd95b98 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -1788,7 +1788,7 @@ push_alphas_to_betas(Generator, Consumer, Quota, Q, State) -> maybe_write_to_disk(true, false, MsgStatus, State), MsgStatus2 = m(trim_msg_status(MsgStatus1)), State2 = Consumer(MsgStatus2, Qa, - upd_ram_counts(1, MsgStatus2, State1)), + upd_ram_counts(-1, MsgStatus2, State1)), push_alphas_to_betas(Generator, Consumer, Quota - 1, Qa, State2) end |