definition_import_SUITE: Skip import_case13 if quorum_queues are unsupported

We need this because the testcase fails in a mixed-version cluster
situation if the other node does not support quorum queues.

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