Skip to content

Commit 71f921c

Browse files
Ayanda-Dmichaelklishin
authored andcommitted
support members info item in classic queues, which will always be the leader
1 parent f9e5d34 commit 71f921c

File tree

2 files changed

+5
-2
lines changed

2 files changed

+5
-2
lines changed

deps/rabbit/src/rabbit_amqqueue_process.erl

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -120,7 +120,8 @@
120120
owner_pid,
121121
exclusive,
122122
user_who_performed_action,
123-
leader
123+
leader,
124+
members
124125
]).
125126

126127
-define(INFO_KEYS, [pid | ?CREATION_EVENT_KEYS ++ ?STATISTICS_KEYS -- [name, type]]).
@@ -1085,6 +1086,7 @@ i(arguments, #q{q = Q}) -> amqqueue:get_arguments(Q);
10851086
i(pid, _) ->
10861087
self();
10871088
i(leader, State) -> node(i(pid, State));
1089+
i(members, State) -> [i(leader, State)];
10881090
i(owner_pid, #q{q = Q}) when ?amqqueue_exclusive_owner_is(Q, none) ->
10891091
'';
10901092
i(owner_pid, #q{q = Q}) ->

deps/rabbit/test/classic_queue_SUITE.erl

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -83,7 +83,8 @@ leader_locator_client_local(Config) ->
8383
{<<"x-queue-leader-locator">>, longstr, <<"client-local">>}])),
8484
{ok, Leader0} = rabbit_ct_broker_helpers:rpc(Config, Server, rabbit_amqqueue, lookup, [rabbit_misc:r(<<"/">>, queue, Q)]),
8585
Leader = amqqueue:qnode(Leader0),
86-
?assertEqual([{leader, Leader}], rabbit_ct_broker_helpers:rpc(Config, Server, rabbit_amqqueue, info, [Leader0, [leader]])),
86+
?assertEqual([{leader, Leader}, {members, [Leader]}],
87+
rabbit_ct_broker_helpers:rpc(Config, Server, rabbit_amqqueue, info, [Leader0, [leader, members]])),
8788
?assertEqual(Server, Leader),
8889
?assertMatch(#'queue.delete_ok'{},
8990
amqp_channel:call(Ch, #'queue.delete'{queue = Q}))

0 commit comments

Comments
 (0)