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:38:35 +0000 |
| commit | dcad8a1199ab0a42c253fae706dc4d28c2e421fc (patch) | |
| tree | c9f283e0d053eeb9bc0433dea3be8da607c19e37 | |
| parent | 1f8f248a88d699efe962891f678189ddd859d681 (diff) | |
| download | rabbitmq-server-git-dcad8a1199ab0a42c253fae706dc4d28c2e421fc.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, |