diff options
| -rw-r--r-- | src/rabbit_variable_queue.erl | 6 |
1 files changed, 2 insertions, 4 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index 50d840ef40..a77301d37d 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -2026,11 +2026,9 @@ push_betas_to_deltas(Generator, LimitFun, Q, PushState) -> end end. -push_betas_to_deltas1(_Generator, _Limit, Q, - {0, Delta, State}) -> +push_betas_to_deltas1(_Generator, _Limit, Q, {0, Delta, State}) -> {Q, {0, Delta, ui(State)}}; -push_betas_to_deltas1(Generator, Limit, Q, - {Quota, Delta, State}) -> +push_betas_to_deltas1(Generator, Limit, Q, {Quota, Delta, State}) -> case Generator(Q) of {empty, _Q} -> {Q, {Quota, Delta, ui(State)}}; |