summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAlexandru Scvortov <alexandru@rabbitmq.com>2011-01-21 13:09:02 +0000
committerAlexandru Scvortov <alexandru@rabbitmq.com>2011-01-21 13:09:02 +0000
commit1c6a0dc5564505e30c74155288e52d1df2458103 (patch)
tree6b824a8951a01006a6165372301b31d406fcda0a
parent19a654b6430350613e16652050fd4d18c16f13c6 (diff)
downloadrabbitmq-server-1c6a0dc5564505e30c74155288e52d1df2458103.tar.gz
fold cases
-rw-r--r--src/rabbit_channel.erl14
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;