|
18 | 18 | -import(rabbit_amqp_util, |
19 | 19 | [has_capability/2]). |
20 | 20 |
|
21 | | --import(rabbit_ct_broker_helpers, [rpc/5]). |
| 21 | +-import(rabbit_ct_broker_helpers, |
| 22 | + [enable_feature_flag/2, |
| 23 | + rpc/5]). |
22 | 24 |
|
23 | 25 | -define(SOLE_CONN_MOD, rabbit_amqp_sole_conn). |
24 | 26 | -define(NODE_COUNT, 3). |
@@ -46,19 +48,32 @@ end_per_suite(Config) -> |
46 | 48 | Config. |
47 | 49 |
|
48 | 50 | init_per_group(cluster, Config) -> |
| 51 | + {ok, _} = application:ensure_all_started(amqp10_client), |
| 52 | + rabbit_ct_helpers:log_environment(), |
49 | 53 | Suffix = rabbit_ct_helpers:testcase_absname(Config, "", "-"), |
50 | 54 | Config1 = rabbit_ct_helpers:set_config( |
51 | 55 | Config, [{rmq_nodes_count, ?NODE_COUNT}, |
52 | 56 | {rmq_nodes_clustered, true}, |
53 | 57 | {rmq_nodename_suffix, Suffix}, |
54 | 58 | {net_ticktime, ?NET_TICKTIME_S}]), |
55 | | - rabbit_ct_helpers:run_setup_steps( |
56 | | - Config1, |
57 | | - [fun rabbit_ct_broker_helpers:configure_dist_proxy/1] ++ |
58 | | - rabbit_ct_broker_helpers:setup_steps() ++ |
59 | | - rabbit_ct_client_helpers:setup_steps()). |
| 59 | + Config2 = rabbit_ct_helpers:run_setup_steps( |
| 60 | + Config1, |
| 61 | + [fun rabbit_ct_broker_helpers:configure_dist_proxy/1] ++ |
| 62 | + rabbit_ct_broker_helpers:setup_steps() ++ |
| 63 | + rabbit_ct_client_helpers:setup_steps()), |
| 64 | + |
| 65 | + case enable_feature_flag(Config2, 'rabbitmq_4.4.0') of |
| 66 | + ok -> |
| 67 | + Config2; |
| 68 | + _ -> |
| 69 | + tear_down_cluster(Config2), |
| 70 | + {skip, "sole conn feature not available cluster-wide"} |
| 71 | + end. |
60 | 72 |
|
61 | 73 | end_per_group(_, Config) -> |
| 74 | + tear_down_cluster(Config). |
| 75 | + |
| 76 | +tear_down_cluster(Config) -> |
62 | 77 | rabbit_ct_helpers:run_teardown_steps( |
63 | 78 | Config, |
64 | 79 | rabbit_ct_client_helpers:teardown_steps() ++ |
|
0 commit comments