diff options
author | Emile Joubert <emile@rabbitmq.com> | 2011-07-19 09:47:06 +0100 |
---|---|---|
committer | Emile Joubert <emile@rabbitmq.com> | 2011-07-19 09:47:06 +0100 |
commit | 4f9b1e18de0882229ffea44e2783177c60a666f2 (patch) | |
tree | b5a33c78be286152561f3b9a427eaf03d4f49e1e | |
parent | 19e1278a72feb7101ae5f1af08ef32d9a7e55ff2 (diff) | |
download | rabbitmq-server-4f9b1e18de0882229ffea44e2783177c60a666f2.tar.gz |
Cosmetic
-rw-r--r-- | src/rabbit_backing_queue_qc.erl | 9 |
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)), |