@@ -5905,7 +5905,7 @@ tcp_back_pressure_rabbitmq_internal_flow(QType, Config) ->
59055905session_flow_control_default_max_frame_size (Config ) ->
59065906 QName = atom_to_binary (? FUNCTION_NAME ),
59075907 Address = rabbitmq_amqp_address :queue (QName ),
5908- {_ , Session , LinkPair } = Init = init (Config ),
5908+ {Connection , Session , LinkPair } = init (Config ),
59095909 {ok , _ } = rabbitmq_amqp_client :declare_queue (LinkPair , QName , #{}),
59105910 {ok , Sender } = amqp10_client :attach_sender_link_sync (Session , <<" sender" >>, Address ),
59115911 ok = wait_for_credit (Sender ),
@@ -5964,7 +5964,9 @@ session_flow_control_default_max_frame_size(Config) ->
59645964 ok = amqp10_client :detach_link (Sender ),
59655965 ok = amqp10_client :detach_link (Receiver ),
59665966 {ok , _ } = rabbitmq_amqp_client :delete_queue (LinkPair , QName ),
5967- ok = close (Init ).
5967+ ok = rabbitmq_amqp_client :detach_management_link_pair_sync (LinkPair ),
5968+ ok = end_session_sync (Session ),
5969+ ok = close_connection_sync (Connection ).
59685970
59695971% % Test session flow control with large messages split into multiple transfer frames.
59705972session_flow_control_small_max_frame_size (Config ) ->
0 commit comments