summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMichael Klishin <michael@novemberain.com>2018-09-25 19:24:16 +0300
committerGitHub <noreply@github.com>2018-09-25 19:24:16 +0300
commitee1f21168baa52e6bbd74201be54131640361e5e (patch)
tree433dd3ecc89f9f5ac220ba43c0289d8b4b326d2a
parent981edb986c805ebee77473810558055e4ad24b45 (diff)
parent4b58515e31e02fc0cbd566d758cc3cd30a878463 (diff)
downloadrabbitmq-server-git-ee1f21168baa52e6bbd74201be54131640361e5e.tar.gz
Merge pull request #1701 from rabbitmq/get-empty-stats
Add basic.get_empty stats as a new counter
-rw-r--r--src/rabbit_channel.erl1
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;