diff options
| author | Matthew Sackman <matthew@lshift.net> | 2010-05-18 16:21:50 +0100 |
|---|---|---|
| committer | Matthew Sackman <matthew@lshift.net> | 2010-05-18 16:21:50 +0100 |
| commit | 99b9e4f61cfa0243817ca1ed223248586f176436 (patch) | |
| tree | 50794e0145ce9bf861739640328e6e26826bade9 | |
| parent | 6624f4275edca8898d0ee7020baadf75c543ca4f (diff) | |
| download | rabbitmq-server-git-99b9e4f61cfa0243817ca1ed223248586f176436.tar.gz | |
Removing erroneous conjunctive clause in test
| -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( |