diff options
| author | dcorbacho <dparracorbacho@piotal.io> | 2020-09-28 11:25:24 +0100 |
|---|---|---|
| committer | dcorbacho <dparracorbacho@piotal.io> | 2020-09-28 11:25:24 +0100 |
| commit | ff21f537d7e71dabfaf09eb121d1249e947ef1c3 (patch) | |
| tree | a98bcf2336de4a9239cf9b482669dd5305683f9c | |
| parent | 6f1d76d68c1083ffeee506514f42c6ccd0e09533 (diff) | |
| download | rabbitmq-server-git-ff21f537d7e71dabfaf09eb121d1249e947ef1c3.tar.gz | |
Exclude consumers suspected as down from the consumer count
| -rw-r--r-- | src/rabbit_fifo.erl | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/src/rabbit_fifo.erl b/src/rabbit_fifo.erl index 79b2bb4f72..85d173f39a 100644 --- a/src/rabbit_fifo.erl +++ b/src/rabbit_fifo.erl @@ -848,7 +848,10 @@ query_ra_indexes(#?MODULE{ra_indexes = RaIndexes}) -> query_consumer_count(#?MODULE{consumers = Consumers, waiting_consumers = WaitingConsumers}) -> - maps:size(Consumers) + length(WaitingConsumers). + Up = maps:filter(fun(_ConsumerId, #consumer{status = Status}) -> + Status =/= suspected_down + end, Consumers), + maps:size(Up) + length(WaitingConsumers). query_consumers(#?MODULE{consumers = Consumers, waiting_consumers = WaitingConsumers, |