diff options
| author | Diana Corbacho <diana@rabbitmq.com> | 2019-02-01 10:00:20 +0000 |
|---|---|---|
| committer | Diana Corbacho <diana@rabbitmq.com> | 2019-02-01 11:55:45 +0000 |
| commit | e3d3371ecaf3a0607be4fc8a1b49ab6f8a310073 (patch) | |
| tree | c9d00282dc4ab29141ddf644f37b8d7698d1966a /src | |
| parent | 3fc685baf932ecbec69b2fa95dcd35b7e3aec3dd (diff) | |
| download | rabbitmq-server-git-e3d3371ecaf3a0607be4fc8a1b49ab6f8a310073.tar.gz | |
Use queue name instead of ra name to query messages metric
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_quorum_queue.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_quorum_queue.erl b/src/rabbit_quorum_queue.erl index b4edca7937..5c061a529d 100644 --- a/src/rabbit_quorum_queue.erl +++ b/src/rabbit_quorum_queue.erl @@ -706,7 +706,7 @@ i(durable, #amqqueue{durable = Dur}) -> Dur; i(auto_delete, #amqqueue{auto_delete = AD}) -> AD; i(arguments, #amqqueue{arguments = Args}) -> Args; i(pid, #amqqueue{pid = {Name, _}}) -> whereis(Name); -i(messages, #amqqueue{pid = {Name, _}}) -> +i(messages, #amqqueue{name = Name}) -> quorum_messages(Name); i(messages_ready, #amqqueue{name = QName}) -> case ets:lookup(queue_coarse_metrics, QName) of |