diff options
| author | Loïc Hoguin <lhoguin@vmware.com> | 2022-10-25 13:04:25 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-10-25 13:04:25 +0200 |
| commit | 6d64d2fc2ca94d55c67d120a6be2a2357a2094e8 (patch) | |
| tree | 0b6c7099d3d6131d8b5efdcd3883d0b48912c9e7 | |
| parent | 00b6c9166d2d9e5421c97fd2dcabaa1c66256e12 (diff) | |
| parent | 7e91bd357a8bbf6dbc97ba83cd103a55ad287559 (diff) | |
| download | rabbitmq-server-git-6d64d2fc2ca94d55c67d120a6be2a2357a2094e8.tar.gz | |
Merge pull request #6239 from rabbitmq/mergify/bp/v3.11.x/pr-6237
Fix the CQ Observer CLI plugin with clusters (backport #6237)
| -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 73227b0835..f7cf3ae122 100644 --- a/deps/rabbit/src/rabbit_observer_cli_classic_queues.erl +++ b/deps/rabbit/src/rabbit_observer_cli_classic_queues.erl @@ -58,12 +58,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), [ |