summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorEmile Joubert <emile@rabbitmq.com>2011-07-19 09:47:06 +0100
committerEmile Joubert <emile@rabbitmq.com>2011-07-19 09:47:06 +0100
commit4f9b1e18de0882229ffea44e2783177c60a666f2 (patch)
treeb5a33c78be286152561f3b9a427eaf03d4f49e1e
parent19e1278a72feb7101ae5f1af08ef32d9a7e55ff2 (diff)
downloadrabbitmq-server-4f9b1e18de0882229ffea44e2783177c60a666f2.tar.gz
Cosmetic
-rw-r--r--src/rabbit_backing_queue_qc.erl9
1 files changed, 6 insertions, 3 deletions
diff --git a/src/rabbit_backing_queue_qc.erl b/src/rabbit_backing_queue_qc.erl
index 1afe20ce..e372e351 100644
--- a/src/rabbit_backing_queue_qc.erl
+++ b/src/rabbit_backing_queue_qc.erl
@@ -223,8 +223,10 @@ next_state(S, Res, {call, ?BQMOD, fetch, [AckReq, _BQ]}) ->
{{value, MsgProp_Msg}, M2} ->
S2 = S1#state{len = Len - 1, messages = M2},
case AckReq of
- true -> S2#state{acks = orddict:append(AckTag, MsgProp_Msg, Acks)};
- false -> S2
+ true ->
+ S2#state{acks = orddict:append(AckTag, MsgProp_Msg, Acks)};
+ false ->
+ S2
end
end;
@@ -239,7 +241,8 @@ next_state(S, Res, {call, ?BQMOD, ack, [AcksArg, _BQ]}) ->
next_state(S, Res, {call, ?BQMOD, requeue, [AcksArg, _F, _V]}) ->
#state{len = Len, messages = Messages, acks = AcksState} = S,
BQ1 = {call, erlang, element, [2, Res]},
- RequeueMsgs = lists:append([orddict:fetch(Key, AcksState) || Key <- AcksArg]),
+ RequeueMsgs = lists:append([orddict:fetch(Key, AcksState) ||
+ Key <- AcksArg]),
S#state{bqstate = BQ1,
len = Len + length(RequeueMsgs),
messages = queue:join(Messages, queue:from_list(RequeueMsgs)),