Skip to content

Commit

Permalink
test and assert new classic queue leader info item
Browse files Browse the repository at this point in the history
  • Loading branch information
Ayanda-D authored and michaelklishin committed Oct 2, 2024
1 parent 22b433e commit f9e5d34
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions deps/rabbit/test/classic_queue_SUITE.erl
Original file line number Diff line number Diff line change
Expand Up @@ -83,6 +83,7 @@ leader_locator_client_local(Config) ->
{<<"x-queue-leader-locator">>, longstr, <<"client-local">>}])),
{ok, Leader0} = rabbit_ct_broker_helpers:rpc(Config, Server, rabbit_amqqueue, lookup, [rabbit_misc:r(<<"/">>, queue, Q)]),
Leader = amqqueue:qnode(Leader0),
?assertEqual([{leader, Leader}], rabbit_ct_broker_helpers:rpc(Config, Server, rabbit_amqqueue, info, [Leader0, [leader]])),
?assertEqual(Server, Leader),
?assertMatch(#'queue.delete_ok'{},
amqp_channel:call(Ch, #'queue.delete'{queue = Q}))
Expand Down

0 comments on commit f9e5d34

Please sign in to comment.