summaryrefslogtreecommitdiff
path: root/src
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
commit3695364c713b5a5476c61233eaea41a4beabf890 (patch)
tree6b824a8951a01006a6165372301b31d406fcda0a /src
parentaf57a26e9a1a44ee9765460a07402c55e5583957 (diff)
downloadrabbitmq-server-git-3695364c713b5a5476c61233eaea41a4beabf890.tar.gz
fold cases
Diffstat (limited to 'src')
-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 40337843ed..fbf0e573d7 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;