diff options
| -rw-r--r-- | test/definition_import_SUITE.erl | 40 |
1 files changed, 23 insertions, 17 deletions
diff --git a/test/definition_import_SUITE.erl b/test/definition_import_SUITE.erl index 376d4d66d2..ac0c18da99 100644 --- a/test/definition_import_SUITE.erl +++ b/test/definition_import_SUITE.erl @@ -117,23 +117,29 @@ import_case11(Config) -> import_file_case(Config, "case11"). import_case12(Config) -> import_invalid_file_case(Config, "failing_case12"). import_case13(Config) -> - import_file_case(Config, "case13"), - VHost = <<"/">>, - QueueName = <<"definitions.import.case13.qq.1">>, - QueueIsImported = fun () -> - case queue_lookup(Config, VHost, QueueName) of - {ok, _} -> true; - _ -> false - end - end, - rabbit_ct_helpers:await_condition(QueueIsImported, 20000), - {ok, Q} = queue_lookup(Config, VHost, QueueName), - - %% see rabbitmq/rabbitmq-server#2400, rabbitmq/rabbitmq-server#2426 - ?assert(amqqueue:is_quorum(Q)), - ?assertEqual([{<<"x-max-length">>, long, 991}, - {<<"x-queue-type">>, longstr, <<"quorum">>}], - amqqueue:get_arguments(Q)). + case rabbit_ct_broker_helpers:enable_feature_flag(Config, quorum_queue) of + ok -> + import_file_case(Config, "case13"), + VHost = <<"/">>, + QueueName = <<"definitions.import.case13.qq.1">>, + QueueIsImported = + fun () -> + case queue_lookup(Config, VHost, QueueName) of + {ok, _} -> true; + _ -> false + end + end, + rabbit_ct_helpers:await_condition(QueueIsImported, 20000), + {ok, Q} = queue_lookup(Config, VHost, QueueName), + + %% see rabbitmq/rabbitmq-server#2400, rabbitmq/rabbitmq-server#2426 + ?assert(amqqueue:is_quorum(Q)), + ?assertEqual([{<<"x-max-length">>, long, 991}, + {<<"x-queue-type">>, longstr, <<"quorum">>}], + amqqueue:get_arguments(Q)); + Skip -> + Skip + end. export_import_round_trip_case1(Config) -> %% case 6 has runtime parameters that do not depend on any plugins |