Skip to content

Commit 8af3db2

Browse files
Wait for connection and session events
1 parent 41dbb61 commit 8af3db2

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

deps/amqp10_client/test/system_SUITE.erl

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -395,7 +395,15 @@ roundtrip(OpenConf, Args, DoNotAssertMessageProperties) ->
395395
<<"x_key">> => <<"x_value">>}),
396396

397397
{ok, Connection} = amqp10_client:open_connection(OpenConf),
398+
receive
399+
{amqp10_event, {connection, Connection, opened}} -> ok
400+
after 5000 -> exit(connection_timeout)
401+
end,
398402
{ok, Session} = amqp10_client:begin_session(Connection),
403+
receive
404+
{amqp10_event, {session, Session, begun}} -> ok
405+
after 5000 -> exit(connection_timeout)
406+
end,
399407
SenderAttachArgs = #{name => <<"banana-sender">>,
400408
role => {sender, #{address => Destination,
401409
durable => unsettled_state,

0 commit comments

Comments
 (0)