Skip to content

Commit d5635a4

Browse files
committed
Use rabbit_misc:rpc_call/5 for RPC
It handles common RPC errors. References #4622
1 parent f3dfb50 commit d5635a4

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

deps/rabbit/src/rabbit_stream_queue.erl

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -492,7 +492,11 @@ i(consumers, Q) when ?is_amqqueue(Q) ->
492492
#{nodes := Nodes} = amqqueue:get_type_state(Q),
493493
Spec = [{{{'$1', '_', '_'}, '_', '_', '_', '_', '_', '_'}, [{'==', {QName}, '$1'}], [true]}],
494494
lists:foldl(fun(N, Acc) ->
495-
case rpc:call(N, ets, select_count,[consumer_created, Spec], 10000) of
495+
case rabbit_misc:rpc_call(N,
496+
ets,
497+
select_count,
498+
[consumer_created, Spec],
499+
10000) of
496500
Count when is_integer(Count) ->
497501
Acc + Count;
498502
_ ->

0 commit comments

Comments
 (0)