Skip to content

Commit 2e67915

Browse files
committed
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}}}} ``` (cherry picked from commit d7f2942)
1 parent 0c9195a commit 2e67915

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

deps/rabbit/test/amqp_client_SUITE.erl

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3108,6 +3108,10 @@ leader_transfer(QName, QType, Credit, Config) ->
31083108
ok = wait_for_accepts(NumMsgs),
31093109
ok = detach_link_sync(Sender),
31103110

3111+
%% Wait a bit to avoid the following error when attaching:
3112+
%% "stream queue <name> does not have a running replica on the local node"
3113+
timer:sleep(50),
3114+
31113115
Filter = consume_from_first(QType),
31123116
{ok, Receiver} = amqp10_client:attach_receiver_link(
31133117
Session0, <<"receiver">>, Address,

0 commit comments

Comments
 (0)