@@ -322,6 +322,10 @@ init_per_testcase(T, Config)
322
322
init_per_testcase (Testcase , Config ) ->
323
323
ClusterSize = ? config (rmq_nodes_count , Config ),
324
324
IsMixed = rabbit_ct_helpers :is_mixed_versions (),
325
+ RabbitMQ3 = case rabbit_ct_broker_helpers :enable_feature_flag (Config , 'rabbitmq_4.0.0' ) of
326
+ ok -> false ;
327
+ _ -> true
328
+ end ,
325
329
SameKhepriMacVers = (
326
330
rabbit_ct_broker_helpers :do_nodes_run_same_ra_machine_version (
327
331
Config , khepri_machine )),
@@ -359,6 +363,8 @@ init_per_testcase(Testcase, Config) ->
359
363
{skip , " reclaim_memory_with_wrong_queue_type isn't mixed versions compatible" };
360
364
peek_with_wrong_queue_type when IsMixed ->
361
365
{skip , " peek_with_wrong_queue_type isn't mixed versions compatible" };
366
+ cancel_consumer_gh_3729 when IsMixed andalso RabbitMQ3 ->
367
+ {skip , " this test is not compatible with RabbitMQ 3.13.x" };
362
368
_ ->
363
369
Config1 = rabbit_ct_helpers :testcase_started (Config , Testcase ),
364
370
rabbit_ct_broker_helpers :rpc (Config , 0 , ? MODULE , delete_queues , []),
@@ -1535,7 +1541,7 @@ force_checkpoint(Config) ->
1535
1541
ForceCheckpointRes = rabbit_ct_broker_helpers :rpc (Config , 0 , rabbit_quorum_queue ,
1536
1542
force_checkpoint , [<<" .*" >>, <<" .*" >>]),
1537
1543
ExpectedRes = [{QQName , {ok }}],
1538
-
1544
+
1539
1545
% Result should only have quorum queue
1540
1546
? assertEqual (ExpectedRes , ForceCheckpointRes ).
1541
1547
@@ -2494,8 +2500,6 @@ metrics_cleanup_on_leader_crash(Config) ->
2494
2500
publish (Ch , QQ ),
2495
2501
publish (Ch , QQ ),
2496
2502
2497
- wait_for_messages_ready ([Server ], RaName , 3 ),
2498
- wait_for_messages_pending_ack ([Server ], RaName , 0 ),
2499
2503
{ok , _ , {Name , Leader }} = ra :members ({RaName , Server }),
2500
2504
QRes = rabbit_misc :r (<<" /" >>, queue , QQ ),
2501
2505
rabbit_ct_helpers :await_condition (
0 commit comments