diff options
| -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); |