@@ -296,6 +296,11 @@ join_when_ram_node_type_is_permitted_by_default_khepri(Config) ->
296296 [NodeA , NodeB ] = rabbit_ct_broker_helpers :get_node_configs (
297297 Config , nodename ),
298298
299+ IsPermitted = rabbit_ct_broker_helpers :rpc (
300+ Config , NodeA ,
301+ rabbit_deprecated_features , is_permitted ,
302+ [ram_node_type ]),
303+
299304 ok = rabbit_control_helper :command (stop_app , NodeA ),
300305 ? assertMatch (
301306 {error , 70 ,
@@ -305,6 +310,12 @@ join_when_ram_node_type_is_permitted_by_default_khepri(Config) ->
305310 [atom_to_list (NodeB )], [{" --ram" , true }])),
306311 ok = rabbit_control_helper :command (start_app , NodeA ),
307312
313+ ? assertEqual (
314+ IsPermitted ,
315+ rabbit_ct_broker_helpers :rpc (
316+ Config , NodeA ,
317+ rabbit_deprecated_features , is_permitted , [ram_node_type ])),
318+
308319 ? assertEqual ([NodeA ], get_all_nodes (Config , NodeA )),
309320 ? assertEqual ([NodeB ], get_all_nodes (Config , NodeB )),
310321 ? assertEqual ([NodeA ], get_disc_nodes (Config , NodeA )),
@@ -357,6 +368,11 @@ join_when_ram_node_type_is_not_permitted_from_conf_khepri(Config) ->
357368 [NodeA , NodeB ] = rabbit_ct_broker_helpers :get_node_configs (
358369 Config , nodename ),
359370
371+ IsPermitted = rabbit_ct_broker_helpers :rpc (
372+ Config , NodeA ,
373+ rabbit_deprecated_features , is_permitted ,
374+ [ram_node_type ]),
375+
360376 ok = rabbit_control_helper :command (stop_app , NodeA ),
361377 ? assertMatch (
362378 {error , 70 ,
@@ -366,6 +382,12 @@ join_when_ram_node_type_is_not_permitted_from_conf_khepri(Config) ->
366382 [atom_to_list (NodeB )], [{" --ram" , true }])),
367383 ok = rabbit_control_helper :command (start_app , NodeA ),
368384
385+ ? assertEqual (
386+ IsPermitted ,
387+ rabbit_ct_broker_helpers :rpc (
388+ Config , NodeA ,
389+ rabbit_deprecated_features , is_permitted , [ram_node_type ])),
390+
369391 ? assertEqual ([NodeA ], get_all_nodes (Config , NodeA )),
370392 ? assertEqual ([NodeB ], get_all_nodes (Config , NodeB )),
371393 ? assertEqual ([NodeA ], get_disc_nodes (Config , NodeA )),
0 commit comments