@@ -5905,7 +5905,7 @@ tcp_back_pressure_rabbitmq_internal_flow(QType, Config) ->
5905
5905
session_flow_control_default_max_frame_size (Config ) ->
5906
5906
QName = atom_to_binary (? FUNCTION_NAME ),
5907
5907
Address = rabbitmq_amqp_address :queue (QName ),
5908
- {_ , Session , LinkPair } = Init = init (Config ),
5908
+ {Connection , Session , LinkPair } = init (Config ),
5909
5909
{ok , _ } = rabbitmq_amqp_client :declare_queue (LinkPair , QName , #{}),
5910
5910
{ok , Sender } = amqp10_client :attach_sender_link_sync (Session , <<" sender" >>, Address ),
5911
5911
ok = wait_for_credit (Sender ),
@@ -5964,7 +5964,9 @@ session_flow_control_default_max_frame_size(Config) ->
5964
5964
ok = amqp10_client :detach_link (Sender ),
5965
5965
ok = amqp10_client :detach_link (Receiver ),
5966
5966
{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 ).
5968
5970
5969
5971
% % Test session flow control with large messages split into multiple transfer frames.
5970
5972
session_flow_control_small_max_frame_size (Config ) ->
0 commit comments