@@ -436,7 +436,6 @@ mirror_queue_auto_ack(Config) ->
436
436
% % Retrieve slaves
437
437
SPids = slave_pids (Config , A , rabbit_misc :r (<<" /" >>, queue , Q )),
438
438
[{SNode1 , _SPid1 }, {SNode2 , SPid2 }] = nodes_and_pids (SPids ),
439
- rabbit_ct_client_helpers :close_channel (Ch ),
440
439
441
440
% % Restart one of the slaves so `request_depth` is triggered
442
441
rabbit_ct_broker_helpers :restart_node (Config , SNode1 ),
@@ -447,8 +446,8 @@ mirror_queue_auto_ack(Config) ->
447
446
SPid2 = proplists :get_value (SNode2 , Slaves ),
448
447
449
448
delete (Ch , Q ),
449
+ rabbit_ct_client_helpers :close_channel (Ch ),
450
450
rabbit_ct_client_helpers :close_connection (Conn ),
451
-
452
451
passed .
453
452
454
453
mirror_queue_sync_order (Config ) ->
@@ -477,6 +476,7 @@ mirror_queue_sync_order(Config) ->
477
476
<<" msg4" >>, <<" msg1" >>]),
478
477
479
478
delete (Ch2 , Q ),
479
+ rabbit_ct_broker_helpers :start_node (Config , A ),
480
480
rabbit_ct_client_helpers :close_connection (Conn ),
481
481
rabbit_ct_client_helpers :close_connection (Conn2 ),
482
482
passed .
0 commit comments