diff options
| author | Diana Corbacho <diana@rabbitmq.com> | 2018-09-17 10:58:24 +0100 |
|---|---|---|
| committer | Diana Corbacho <diana@rabbitmq.com> | 2018-09-17 10:58:33 +0100 |
| commit | 4b58515e31e02fc0cbd566d758cc3cd30a878463 (patch) | |
| tree | 0712f325f8a7b39cbd7adfee950ee9b81aa90b71 | |
| parent | 8f71523f001aa484fa514724dee15ed9ace87adc (diff) | |
| download | rabbitmq-server-git-4b58515e31e02fc0cbd566d758cc3cd30a878463.tar.gz | |
Add get empty stats as a new counter
Basic.get requests that return ok_empty used to be unaccounted for
[#160280626]
| -rw-r--r-- | src/rabbit_channel.erl | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index b2274fe877..f270f2cc66 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -1172,6 +1172,7 @@ handle_method(#'basic.get'{queue = QueueNameBin, no_ack = NoAck}, State1 = monitor_delivering_queue(NoAck, QPid, QName, State), {noreply, record_sent(none, not(NoAck), Msg, State1)}; empty -> + ?INCR_STATS(queue_stats, QueueName, 1, get_empty, State), {reply, #'basic.get_empty'{}, State} end; |