diff options
| -rw-r--r-- | src/rabbit_variable_queue.erl | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index 4f9666c7f3..4d6e6e040c 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -1299,10 +1299,10 @@ maybe_deltas_to_betas(State = #vqstate { index_state = IndexState, target_ram_msg_count = TargetRamMsgCount, transient_threshold = TransientThreshold }) -> - case (not bpqueue:is_empty(Q3)) andalso (0 == TargetRamMsgCount) of - true -> - State; + case bpqueue:is_empty(Q3) orelse (TargetRamMsgCount /= 0) of false -> + State; + true -> #delta { start_seq_id = DeltaSeqId, count = DeltaCount, end_seq_id = DeltaSeqIdEnd } = Delta, |