diff options
| author | Rob Harrop <rharrop@vmware.com> | 2010-09-28 12:20:27 +0100 |
|---|---|---|
| committer | Rob Harrop <rharrop@vmware.com> | 2010-09-28 12:20:27 +0100 |
| commit | 4dcbcd311d9d17caf3b9cf69fb92d8b9fd1ac0b9 (patch) | |
| tree | 9ff053a4e905b90676805e025ff43e86aa2917e8 | |
| parent | 4591acbd2944bfcbac7316919b3c8eb5f450e56a (diff) | |
| download | rabbitmq-server-git-4dcbcd311d9d17caf3b9cf69fb92d8b9fd1ac0b9.tar.gz | |
cosmetic
| -rw-r--r-- | src/rabbit_invariable_queue.erl | 3 | ||||
| -rw-r--r-- | src/rabbit_persister.erl | 3 |
2 files changed, 4 insertions, 2 deletions
diff --git a/src/rabbit_invariable_queue.erl b/src/rabbit_invariable_queue.erl index 59c678c92a..b62544fada 100644 --- a/src/rabbit_invariable_queue.erl +++ b/src/rabbit_invariable_queue.erl @@ -130,7 +130,8 @@ dropwhile(Pred, State = #iv_state { queue = Q }) -> {{value, {Msg, MsgProps, IsDelivered}}, Q1} = queue:out(Q), case Pred(Msg, MsgProps) of true -> - {_, State1} = fetch_internal(false, Q1, Msg, MsgProps, IsDelivered, State), + {_, State1} = + fetch_internal(false, Q1, Msg, MsgProps, IsDelivered, State), dropwhile(Pred, State1); false -> State diff --git a/src/rabbit_persister.erl b/src/rabbit_persister.erl index e50d33235b..513b14dff4 100644 --- a/src/rabbit_persister.erl +++ b/src/rabbit_persister.erl @@ -173,7 +173,8 @@ handle_call(force_snapshot, _From, State) -> handle_call({queue_content, QName}, _From, State = #pstate{snapshot = #psnapshot{messages = Messages, queues = Queues}}) -> - MatchSpec= [{{{QName,'$1'}, '$2', '$3', '$4'}, [], [{{'$4', '$1', '$2', '$3'}}]}], + MatchSpec= [{{{QName,'$1'}, '$2', '$3', '$4'}, [], + [{{'$4', '$1', '$2', '$3'}}]}], do_reply([{ets:lookup_element(Messages, K, 2), MP, D} || {_, K, D, MP} <- lists:sort(ets:select(Queues, MatchSpec))], State); |