diff options
| author | Karl Nilsson <kjnilsson@gmail.com> | 2021-11-08 14:28:42 +0000 |
|---|---|---|
| committer | Karl Nilsson <kjnilsson@gmail.com> | 2021-11-08 14:28:42 +0000 |
| commit | e721ab291f2c1ec2a348d917ff4913cf8b1dc7c6 (patch) | |
| tree | 3f66dd885c520b6faacf2be27caa478fb4b3fe7f | |
| parent | 339322d339300d26179a2ca4a2ca6e9a7669aff2 (diff) | |
| download | rabbitmq-server-git-e721ab291f2c1ec2a348d917ff4913cf8b1dc7c6.tar.gz | |
Fix metric active value when consuming from a QQ
Introduced in 1c6e45257d824ef72b11fad171bb11a88bb9a4b5
| -rw-r--r-- | deps/rabbit/src/rabbit_quorum_queue.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/deps/rabbit/src/rabbit_quorum_queue.erl b/deps/rabbit/src/rabbit_quorum_queue.erl index 9c46adb77b..445345bccd 100644 --- a/deps/rabbit/src/rabbit_quorum_queue.erl +++ b/deps/rabbit/src/rabbit_quorum_queue.erl @@ -771,7 +771,7 @@ consume(Q, Spec, QState0) when ?amqqueue_is_quorum(Q) -> rabbit_core_metrics:consumer_created( ChPid, ConsumerTag, ExclusiveConsume, AckRequired, QName, - ConsumerPrefetchCount, true, %% IsSingleSctiveconsumer + ConsumerPrefetchCount, ActivityStatus == single_active, %% Active ActivityStatus, Args), emit_consumer_created(ChPid, ConsumerTag, ExclusiveConsume, AckRequired, QName, Prefetch, @@ -786,7 +786,7 @@ consume(Q, Spec, QState0) when ?amqqueue_is_quorum(Q) -> rabbit_core_metrics:consumer_created( ChPid, ConsumerTag, ExclusiveConsume, AckRequired, QName, - ConsumerPrefetchCount, false, %% issingleactiveconsumer + ConsumerPrefetchCount, true, %% Active up, Args), emit_consumer_created(ChPid, ConsumerTag, ExclusiveConsume, AckRequired, QName, Prefetch, |