diff options
| author | Matthias Radestock <matthias@lshift.net> | 2009-12-04 12:38:51 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@lshift.net> | 2009-12-04 12:38:51 +0000 |
| commit | 8a435be43cc41ddc626eb04faa399f3e96227fbf (patch) | |
| tree | 8541781d3c9fda6e6eb925ebb557590fb625cc88 | |
| parent | 41805b590d507f3c9a443d48b3661364e052e9ae (diff) | |
| download | rabbitmq-server-git-8a435be43cc41ddc626eb04faa399f3e96227fbf.tar.gz | |
cosmetic
| -rw-r--r-- | src/rabbit_queue_index.erl | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/rabbit_queue_index.erl b/src/rabbit_queue_index.erl index ed469849ff..c95c803365 100644 --- a/src/rabbit_queue_index.erl +++ b/src/rabbit_queue_index.erl @@ -726,10 +726,10 @@ add_to_journal(SeqId, Action, State = #qistate { dirty_count = DCount, segments = segment_store(Segment1, Segments) }; add_to_journal(RelSeq, Action, Segment = - #segment { journal_entries = SegJournal, + #segment { journal_entries = JEntries, pubs = PubCount, acks = AckCount }) -> - SegJournal1 = add_to_journal(RelSeq, Action, SegJournal), - Segment1 = Segment #segment { journal_entries = SegJournal1 }, + JEntries1 = add_to_journal(RelSeq, Action, JEntries), + Segment1 = Segment #segment { journal_entries = JEntries1 }, case Action of del -> Segment1; ack -> Segment1 #segment { acks = AckCount + 1 }; |
