diff options
| author | Matthias Radestock <matthias@lshift.net> | 2009-08-26 06:21:54 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@lshift.net> | 2009-08-26 06:21:54 +0100 |
| commit | 8ba75b2767bb24396dbc9e5707b110f3c382aa08 (patch) | |
| tree | d8cdb5748725bd038a1452c82bee74ca7ebf3626 | |
| parent | 70a6b3d5b5312e704b63750ff0dd27ab2d422134 (diff) | |
| download | rabbitmq-server-git-8ba75b2767bb24396dbc9e5707b110f3c382aa08.tar.gz | |
cosmetic
| -rw-r--r-- | src/rabbit_disk_queue.erl | 12 |
1 files changed, 3 insertions, 9 deletions
diff --git a/src/rabbit_disk_queue.erl b/src/rabbit_disk_queue.erl index ef4ff74e8d..fea0092ee5 100644 --- a/src/rabbit_disk_queue.erl +++ b/src/rabbit_disk_queue.erl @@ -1190,9 +1190,7 @@ internal_delete_queue(Q, State) -> %% now remove everything already delivered Objs = mnesia:dirty_match_object( rabbit_disk_queue, - #dq_msg_loc { queue_and_seq_id = {Q, '_'}, - _ = '_' - }), + #dq_msg_loc { queue_and_seq_id = {Q, '_'}, _ = '_' }), MsgSeqIds = lists:map( fun (#dq_msg_loc { queue_and_seq_id = {_Q, SeqId}, @@ -1651,9 +1649,7 @@ load_messages(Left, [File|Files], fun (Obj = {MsgId, IsPersistent, TotalSize, Offset}, {VMAcc, VTSAcc}) -> case length(mnesia:dirty_index_match_object (rabbit_disk_queue, - #dq_msg_loc { msg_id = MsgId, - _ = '_' - }, + #dq_msg_loc { msg_id = MsgId, _ = '_' }, msg_id)) of 0 -> {VMAcc, VTSAcc}; RefCount -> @@ -1692,9 +1688,7 @@ verify_messages_in_mnesia(MsgIds) -> fun (MsgId) -> true = 0 < length(mnesia:dirty_index_match_object (rabbit_disk_queue, - #dq_msg_loc { msg_id = MsgId, - _ = '_' - }, + #dq_msg_loc { msg_id = MsgId, _ = '_' }, msg_id)) end, MsgIds). |