diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2014-07-28 14:00:39 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2014-07-28 14:00:39 +0100 |
| commit | eb02041e5602d4c09a151827c7a80e3535ea0938 (patch) | |
| tree | b6f0724e8b8e58c5d131abe6371c79c9bda618ce | |
| parent | 97b7295000ce77bfd70c443323976b4b979aec7f (diff) | |
| download | rabbitmq-server-git-eb02041e5602d4c09a151827c7a80e3535ea0938.tar.gz | |
The expectation is we will only return details for persistent messages here.
| -rw-r--r-- | src/rabbit_queue_index.erl | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/src/rabbit_queue_index.erl b/src/rabbit_queue_index.erl index 322c0f8a27..08c81a9480 100644 --- a/src/rabbit_queue_index.erl +++ b/src/rabbit_queue_index.erl @@ -471,11 +471,14 @@ recover_segment(ContainsCheckFun, CleanShutdown, {SegEntries1, UnackedCountDelta} = segment_plus_journal(SegEntries, JEntries), array:sparse_foldl( - fun (RelSeq, {{MsgId, MsgProps, _IsPersistent}, Del, no_ack}, + fun (RelSeq, {{MsgId, MsgProps, IsPersistent}, Del, no_ack}, {SegmentAndDirtyCount, Bytes}) -> {recover_message(ContainsCheckFun(MsgId), CleanShutdown, Del, RelSeq, SegmentAndDirtyCount), - Bytes + MsgProps#message_properties.size} + Bytes + case IsPersistent of + true -> MsgProps#message_properties.size; + false -> 0 + end} end, {{Segment #segment { unacked = UnackedCount + UnackedCountDelta }, 0}, 0}, SegEntries1). |