diff options
| author | Michal Kuratczyk <mkuratczyk@vmware.com> | 2022-10-25 12:14:13 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-10-25 12:14:13 +0200 |
| commit | 5b9941baf660e9130019e7b41c13e16b8a21bb21 (patch) | |
| tree | 22eb3df43a91557b44e761f9a0ad74ebf23690a8 | |
| parent | 2c0290c6ba343769b86b1158363454fd65b53094 (diff) | |
| parent | 640fa95b5b5fb1a12fb4d34b22c8af1dcd19f8f0 (diff) | |
| download | rabbitmq-server-git-5b9941baf660e9130019e7b41c13e16b8a21bb21.tar.gz | |
Merge pull request #6237 from rabbitmq/loic-fix-observer-cli-cq-cluster
Fix the CQ Observer CLI plugin with clusters
| -rw-r--r-- | deps/rabbit/src/rabbit_observer_cli_classic_queues.erl | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/deps/rabbit/src/rabbit_observer_cli_classic_queues.erl b/deps/rabbit/src/rabbit_observer_cli_classic_queues.erl index 3ce68e7f37..5366e48d90 100644 --- a/deps/rabbit/src/rabbit_observer_cli_classic_queues.erl +++ b/deps/rabbit/src/rabbit_observer_cli_classic_queues.erl @@ -59,12 +59,13 @@ sheet_body(State) -> ["dead", Vhost, unicode:characters_to_binary([Name, " (dead)"]), 0,0,0,0,0,0,0,0,0,0]; Pid -> - case process_info(Pid, message_queue_len) of + ProcInfo = erpc:call(node(Pid), erlang, process_info, [Pid, message_queue_len]), + case ProcInfo of undefined -> [Pid, Vhost, unicode:characters_to_binary([Name, " (dead)"]), 0,0,0,0,0,0,0,0,0,0]; {_, MsgQ} -> - GS2Q = rabbit_core_metrics:get_gen_server2_stats(Pid), + GS2Q = erpc:call(node(Pid), rabbit_core_metrics, get_gen_server2_stats, [Pid]), Info = rabbit_amqqueue:info(Q), BQInfo = proplists:get_value(backing_queue_status, Info), [ |