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

Poll with basic.get in test 

To make sure to get the message.
This commit is contained in:
Arnaud Cogoluègnes 2023-04-05 14:35:55 +02:00
parent 01f6d0fc19
commit b840200798
No known key found for this signature in database
GPG Key ID: D5C8C4DFAD43AFA8
1 changed files with 14 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
deps/rabbit/test/quorum_queue_SUITE.erl vendored
View File

@ -921,10 +921,10 @@ reject_after_leader_transfer(Config) ->
Ch2 = rabbit_ct_client_helpers:open_channel(Config, Server2), Ch2 = rabbit_ct_client_helpers:open_channel(Config, Server2),
{#'basic.get_ok'{delivery_tag = Tag}, #amqp_msg{}} = {#'basic.get_ok'{delivery_tag = Tag}, #amqp_msg{}} =
amqp_channel:call(Ch2, #'basic.get'{queue = QQ, no_ack = false}), basic_get(Ch2, QQ, false, 10),
ServerId1 = {RaName, Server1}, ServerId1 = {RaName, Server1},
ct:pal("transfser leadership ~p", ct:pal("transfer leadership ~p",
[rabbit_ct_broker_helpers:rpc(Config, 0, ra, [rabbit_ct_broker_helpers:rpc(Config, 0, ra,
transfer_leadership, [ServerId1, ServerId1])]), transfer_leadership, [ServerId1, ServerId1])]),
ok = amqp_channel:call(Ch2, #'basic.reject'{delivery_tag = Tag, ok = amqp_channel:call(Ch2, #'basic.reject'{delivery_tag = Tag,
@ -932,7 +932,7 @@ reject_after_leader_transfer(Config) ->
wait_for_messages(Config, [[QQ, <<"1">>, <<"1">>, <<"0">>]]), wait_for_messages(Config, [[QQ, <<"1">>, <<"1">>, <<"0">>]]),
{#'basic.get_ok'{delivery_tag = Tag2}, #amqp_msg{}} = {#'basic.get_ok'{delivery_tag = Tag2}, #amqp_msg{}} =
amqp_channel:call(Ch2, #'basic.get'{queue = QQ, no_ack = false}), basic_get(Ch2, QQ, false, 10),
ok = amqp_channel:call(Ch2, #'basic.reject'{delivery_tag = Tag2, ok = amqp_channel:call(Ch2, #'basic.reject'{delivery_tag = Tag2,
requeue = true}), requeue = true}),
@ -3371,3 +3371,14 @@ validate_queue(Ch, Queue, ExpectedMsgs) ->
end end
end || M <- ExpectedMsgs], end || M <- ExpectedMsgs],
ok. ok.
basic_get(_, _, _, 0) ->
empty;
basic_get(Ch, Q, NoAck, Attempt) ->
case amqp_channel:call(Ch, #'basic.get'{queue = Q, no_ack = NoAck}) of
{#'basic.get_ok'{}, #amqp_msg{}} = R ->
R;
_ ->
timer:sleep(100),
basic_get(Ch, Q, NoAck, Attempt - 1)
end.