diff options
| -rw-r--r-- | deps/amqp10_client/test/system_SUITE.erl | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/deps/amqp10_client/test/system_SUITE.erl b/deps/amqp10_client/test/system_SUITE.erl index 8270b95b36..714dbed65a 100644 --- a/deps/amqp10_client/test/system_SUITE.erl +++ b/deps/amqp10_client/test/system_SUITE.erl @@ -495,6 +495,7 @@ subscribe(Config) -> {ok, Sender} = amqp10_client:attach_sender_link_sync(Session, <<"sub-sender">>, QueueName), + await_link(Sender, credited, link_credit_timeout), _ = publish_messages(Sender, <<"banana">>, 10), {ok, Receiver} = amqp10_client:attach_receiver_link(Session, <<"sub-receiver">>, @@ -524,6 +525,7 @@ subscribe_with_auto_flow(Config) -> {ok, Sender} = amqp10_client:attach_sender_link_sync(Session, <<"sub-sender">>, QueueName), + await_link(Sender, credited, link_credit_timeout), _ = publish_messages(Sender, <<"banana">>, 10), {ok, Receiver} = amqp10_client:attach_receiver_link(Session, <<"sub-receiver">>, |