Skip to content

Commit a432ac7

Browse files
Merge pull request #2064 from rabbitmq/get-empty-qq
Add get empty counter to quorum queues
2 parents 198d2e9 + f78d80f commit a432ac7

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

src/rabbit_channel.erl

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1402,6 +1402,7 @@ handle_method(#'basic.get'{queue = QueueNameBin, no_ack = NoAck},
14021402
handle_basic_get(WriterPid, DeliveryTag, NoAck, MessageCount, Msg,
14031403
State#ch{queue_states = QueueStates});
14041404
{empty, QueueStates} ->
1405+
?INCR_STATS(queue_stats, QueueName, 1, get_empty, State),
14051406
{reply, #'basic.get_empty'{}, State#ch{queue_states = QueueStates}};
14061407
empty ->
14071408
?INCR_STATS(queue_stats, QueueName, 1, get_empty, State),

0 commit comments

Comments
 (0)