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 | aa339008221e32a7281b305bc06801d614cfa148 (patch) | |
| tree | b5a33c78be286152561f3b9a427eaf03d4f49e1e /src | |
| parent | 16c509d4b0c94f6730e10ac7450f9c4f738d02f5 (diff) | |
| download | rabbitmq-server-git-aa339008221e32a7281b305bc06801d614cfa148.tar.gz | |
Cosmetic
Diffstat (limited to 'src')
| -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 1afe20cea0..e372e35130 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)), |
