@@ -63,63 +63,44 @@ end_per_suite(Config) ->
6363 Config .
6464
6565init_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 ());
10487init_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 ());
123104init_per_group (_ , Config ) ->
124105 rabbit_ct_helpers :run_setup_steps (Config ).
125106
0 commit comments