diff options
Diffstat (limited to 'src')
| -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 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; |