@@ -63,63 +63,44 @@ end_per_suite(Config) ->
63
63
Config .
64
64
65
65
init_per_group (Group , Config )
66
- when Group == single_node orelse Group == single_node_1 ->
67
- Config1 =
68
- rabbit_ct_helpers :set_config (Config , [{rmq_nodes_clustered , false }]),
69
- Config2 =
70
- rabbit_ct_helpers :set_config (Config1 ,
71
- {rabbitmq_ct_tls_verify , verify_none }),
72
- Config3 =
73
- rabbit_ct_helpers :set_config (Config2 , {rabbitmq_stream , verify_none }),
74
- % % stream sac feature flag disabled for the first test,
75
- % % then enabled in the end_per_testcase function
76
- ExtraSetupSteps =
77
- case Group of
78
- single_node ->
79
- [fun (StepConfig ) ->
80
- rabbit_ct_helpers :merge_app_env (StepConfig ,
81
- {rabbit ,
82
- [{forced_feature_flags_on_init ,
83
- [classic_mirrored_queue_version ,
84
- stream_queue ]}]})
85
- end ];
86
- _ ->
87
- []
88
- end ,
89
- rabbit_ct_helpers :run_setup_steps (Config3 ,
90
- [fun (StepConfig ) ->
91
- rabbit_ct_helpers :merge_app_env (StepConfig ,
92
- {rabbit ,
93
- [{core_metrics_gc_interval ,
94
- 1000 }]})
95
- end ,
96
- fun (StepConfig ) ->
97
- rabbit_ct_helpers :merge_app_env (StepConfig ,
98
- {rabbitmq_stream ,
99
- [{connection_negotiation_step_timeout ,
100
- 500 }]})
101
- end ]
102
- ++ ExtraSetupSteps
103
- ++ rabbit_ct_broker_helpers :setup_steps ());
66
+ when Group == single_node orelse Group == single_node_1 ->
67
+ Config1 = rabbit_ct_helpers :set_config (
68
+ Config , [{rmq_nodes_clustered , false },
69
+ {rabbitmq_ct_tls_verify , verify_none },
70
+ {rabbitmq_stream , verify_none }
71
+ ]),
72
+ rabbit_ct_helpers :run_setup_steps (
73
+ Config1 ,
74
+ [fun (StepConfig ) ->
75
+ rabbit_ct_helpers :merge_app_env (StepConfig ,
76
+ {rabbit ,
77
+ [{core_metrics_gc_interval ,
78
+ 1000 }]})
79
+ end ,
80
+ fun (StepConfig ) ->
81
+ rabbit_ct_helpers :merge_app_env (StepConfig ,
82
+ {rabbitmq_stream ,
83
+ [{connection_negotiation_step_timeout ,
84
+ 500 }]})
85
+ end ]
86
+ ++ rabbit_ct_broker_helpers :setup_steps ());
104
87
init_per_group (cluster = Group , Config ) ->
105
- Config1 =
106
- rabbit_ct_helpers :set_config (Config , [{rmq_nodes_clustered , true }]),
107
- Config2 =
108
- rabbit_ct_helpers :set_config (Config1 ,
109
- [{rmq_nodes_count , 3 },
110
- {rmq_nodename_suffix , Group },
111
- {tcp_ports_base }]),
112
- Config3 =
113
- rabbit_ct_helpers :set_config (Config2 ,
114
- {rabbitmq_ct_tls_verify , verify_none }),
115
- rabbit_ct_helpers :run_setup_steps (Config3 ,
116
- [fun (StepConfig ) ->
117
- rabbit_ct_helpers :merge_app_env (StepConfig ,
118
- {aten ,
119
- [{poll_interval ,
120
- 1000 }]})
121
- end ]
122
- ++ rabbit_ct_broker_helpers :setup_steps ());
88
+ Config1 = rabbit_ct_helpers :set_config (
89
+ Config , [{rmq_nodes_clustered , true },
90
+ {rmq_nodes_count , 3 },
91
+ {rmq_nodename_suffix , Group },
92
+ {tcp_ports_base },
93
+ {rabbitmq_ct_tls_verify , verify_none }
94
+ ]),
95
+ rabbit_ct_helpers :run_setup_steps (
96
+ Config1 ,
97
+ [fun (StepConfig ) ->
98
+ rabbit_ct_helpers :merge_app_env (StepConfig ,
99
+ {aten ,
100
+ [{poll_interval ,
101
+ 1000 }]})
102
+ end ]
103
+ ++ rabbit_ct_broker_helpers :setup_steps ());
123
104
init_per_group (_ , Config ) ->
124
105
rabbit_ct_helpers :run_setup_steps (Config ).
125
106
0 commit comments