diff options
| author | Michael Klishin <mklishin@pivotal.io> | 2019-08-03 10:07:19 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2019-08-03 10:07:19 +0300 |
| commit | a432ac7a4632df88d3e02675e602cea044666b8c (patch) | |
| tree | 01604f5ee51ad6d8ee62b5ca25a2fd0d95950cac | |
| parent | 198d2e9d887c0f6d4e8bfdf33830773176808f79 (diff) | |
| parent | f78d80f49f93d99597e79ceac3e01050168b3010 (diff) | |
| download | rabbitmq-server-git-a432ac7a4632df88d3e02675e602cea044666b8c.tar.gz | |
Merge pull request #2064 from rabbitmq/get-empty-qq
Add get empty counter to quorum queues
| -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 d16929d962..9859641a00 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -1402,6 +1402,7 @@ handle_method(#'basic.get'{queue = QueueNameBin, no_ack = NoAck}, handle_basic_get(WriterPid, DeliveryTag, NoAck, MessageCount, Msg, State#ch{queue_states = QueueStates}); {empty, QueueStates} -> + ?INCR_STATS(queue_stats, QueueName, 1, get_empty, State), {reply, #'basic.get_empty'{}, State#ch{queue_states = QueueStates}}; empty -> ?INCR_STATS(queue_stats, QueueName, 1, get_empty, State), |