root
/
rabbitmq-server
mirror of https://github.com/rabbitmq/rabbitmq-server.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

tweak

This commit is contained in:
Karl Nilsson 2023-11-07 08:48:57 +00:00
parent c2cd60b18d
commit d77f937ff4
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
deps/rabbit/src/rabbit_quorum_queue.erl vendored
View File

@ -1670,8 +1670,8 @@ peek(_Pos, Q) when ?is_amqqueue(Q) ->
online(Q) when ?is_amqqueue(Q) ->
Nodes = get_connected_nodes(Q),
{Name, _} = amqqueue:get_pid(Q),
[node(Pid) || {ok, Pid} <-
erpc:multicall(Nodes, fun () -> whereis(Name) end),
[node(Pid) || {ok, Pid} <-
erpc:multicall(Nodes, erlang, whereis, [Name]),
is_pid(Pid)].
format(Q, Ctx) when ?is_amqqueue(Q) ->