diff options
author | Alexandru Scvortov <alexandru@rabbitmq.com> | 2011-01-21 13:09:02 +0000 |
---|---|---|
committer | Alexandru Scvortov <alexandru@rabbitmq.com> | 2011-01-21 13:09:02 +0000 |
commit | 1c6a0dc5564505e30c74155288e52d1df2458103 (patch) | |
tree | 6b824a8951a01006a6165372301b31d406fcda0a | |
parent | 19a654b6430350613e16652050fd4d18c16f13c6 (diff) | |
download | rabbitmq-server-1c6a0dc5564505e30c74155288e52d1df2458103.tar.gz |
fold cases
-rw-r--r-- | src/rabbit_channel.erl | 14 |
1 files changed, 4 insertions, 10 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index 40337843..fbf0e573 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -1249,17 +1249,11 @@ lock_message(true, MsgStruct, State = #ch{unacked_message_q = UAMQ}) -> lock_message(false, _MsgStruct, State) -> State. -send_confirms(State = #ch{confirmed = C, stats_timer = StatsTimer}) -> +send_confirms(State = #ch{confirmed = C}) -> C1 = lists:append(C), - MsgSeqNos = case rabbit_event:stats_level(StatsTimer) of - fine -> - [ begin maybe_incr_stats([{ExchangeName, 1}], - confirm, State), - MsgSeqNo - end || {MsgSeqNo, ExchangeName} <- C1]; - _ -> - [MsgSeqNo || {MsgSeqNo, _} <- C1] - end, + MsgSeqNos = [ begin maybe_incr_stats([{ExchangeName, 1}], confirm, State), + MsgSeqNo + end || {MsgSeqNo, ExchangeName} <- C1 ], send_confirms(MsgSeqNos, State #ch{confirmed = []}). send_confirms([], State) -> State; |