|
11 | 11 | -include_lib("eunit/include/eunit.hrl").
|
12 | 12 | -include_lib("amqp_client/include/amqp_client.hrl").
|
13 | 13 | -include_lib("rabbitmq_mqtt/include/rabbit_mqtt.hrl").
|
14 |
| --import(rabbit_web_mqtt_test_util, [connect/3, connect/4]). |
| 14 | + |
| 15 | +-import(rabbit_web_mqtt_test_util, |
| 16 | + [connect/3, connect/4]). |
15 | 17 |
|
16 | 18 | -define(COMMAND, 'Elixir.RabbitMQ.CLI.Ctl.Commands.ListWebMqttConnectionsCommand').
|
17 | 19 |
|
@@ -53,12 +55,11 @@ end_per_suite(Config) ->
|
53 | 55 |
|
54 | 56 | init_per_group(unit, Config) ->
|
55 | 57 | Config;
|
56 |
| -init_per_group(Group, Config) -> |
57 |
| - case rabbit_ct_helpers:is_mixed_versions() of |
58 |
| - true -> |
59 |
| - {skip, "mixed version clusters are not supported"}; |
60 |
| - _ -> |
61 |
| - rabbit_ct_helpers:set_config(Config, {mqtt_version, Group}) |
| 58 | +init_per_group(v5 = V5, Config0) -> |
| 59 | + Config = rabbit_ct_helpers:set_config(Config0, {mqtt_version, V5}), |
| 60 | + case rabbit_ct_broker_helpers:enable_feature_flag(Config, mqtt_v5) of |
| 61 | + ok -> Config; |
| 62 | + {skip, _} = Skip -> Skip |
62 | 63 | end.
|
63 | 64 |
|
64 | 65 | end_per_group(_, Config) ->
|
|
0 commit comments