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

Fix test flake 

Sometimes in CI under Khepri, the test case errored with:
```
receiver_attached flushed: {amqp10_event,
                            {session,<0.396.0>,
                             {ended,
                              {'v1_0.error',
                               {symbol,<<"amqp:internal-error">>},
                               {utf8,
                                <<"stream queue 'leader_transfer_stream_credit_single' in vhost '/' does not have a running replica on the local node">>},
                               undefined}}}}
```
This commit is contained in:
David Ansari 2024-07-30 21:05:25 +02:00
parent 4e3ff2c8ef
commit d7f29426a8
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
deps/rabbit/test/amqp_client_SUITE.erl vendored
View File

@ -3108,6 +3108,10 @@ leader_transfer(QName, QType, Credit, Config) ->
ok = wait_for_accepts(NumMsgs),
ok = detach_link_sync(Sender),
%% Wait a bit to avoid the following error when attaching:
%% "stream queue <name> does not have a running replica on the local node"
timer:sleep(50),
Filter = consume_from_first(QType),
{ok, Receiver} = amqp10_client:attach_receiver_link(
Session0, <<"receiver">>, Address,