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 a3a33377cc..977b1af21b 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -847,8 +847,8 @@ permitted_ram_index_count(#vqstate { len = Len, BetaLen - trunc(BetaLen * BetaLen / AlphaBetaLen) end. -should_force_index_to_disk(State = - #vqstate { ram_index_count = RamIndexCount }) -> +should_force_index_to_disk(State = #vqstate { + ram_index_count = RamIndexCount }) -> case permitted_ram_index_count(State) of infinity -> false; Permitted -> RamIndexCount >= Permitted |