diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_queue_index.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_queue_index.erl b/src/rabbit_queue_index.erl index 39cbf1b36a..40fa0be0bb 100644 --- a/src/rabbit_queue_index.erl +++ b/src/rabbit_queue_index.erl @@ -601,7 +601,7 @@ flush_journal(State = #qistate { segments = Segments }) -> fun (_Seg, #segment { journal_entries = JEntries, pubs = PubCount, acks = AckCount } = Segment, SegmentsN) -> - case PubCount > 0 andalso PubCount == AckCount of + case PubCount =:= AckCount of true -> ok = delete_segment(Segment), SegmentsN; false -> segment_store( |