diff options
| author | Alexandru Scvortov <alexandru@rabbitmq.com> | 2010-12-09 08:24:52 +0000 |
|---|---|---|
| committer | Alexandru Scvortov <alexandru@rabbitmq.com> | 2010-12-09 08:24:52 +0000 |
| commit | a1701d1fc94f65102e5c185c897379d0a5700bdf (patch) | |
| tree | 560a7aaee34524af2ef87f2ddfd13665c184f670 /src | |
| parent | 31cfc20bf6158c0cf21afd4bbb896e3f2204ba0a (diff) | |
| download | rabbitmq-server-git-a1701d1fc94f65102e5c185c897379d0a5700bdf.tar.gz | |
add stats again; update docs
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_channel.erl | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index 9f1f29747f..7471115e10 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -474,6 +474,7 @@ send_or_enqueue_ack(MsgSeqNo, QPid, ExchangeName, maybe_incr_confirm_queue_stats(QPid, ExchangeName, State), do_if_unconfirmed(MsgSeqNo, QPid, fun(MSN, State1 = #ch{writer_pid = WriterPid}) -> + maybe_incr_stats([{ExchangeName, 1}], confirm, State1), ok = rabbit_writer:send_command( WriterPid, #'basic.ack'{ delivery_tag = MSN}), @@ -484,6 +485,7 @@ send_or_enqueue_ack(MsgSeqNo, QPid, ExchangeName, maybe_incr_confirm_queue_stats(QPid, ExchangeName, State), do_if_unconfirmed(MsgSeqNo, QPid, fun(MSN, State1 = #ch{held_confirms = As}) -> + maybe_incr_stats([{ExchangeName, 1}], confirm, State1), start_confirm_timer( State1#ch{held_confirms = gb_sets:add(MSN, As)}) end, State). |