@@ -296,6 +296,11 @@ join_when_ram_node_type_is_permitted_by_default_khepri(Config) ->
296
296
[NodeA , NodeB ] = rabbit_ct_broker_helpers :get_node_configs (
297
297
Config , nodename ),
298
298
299
+ IsPermitted = rabbit_ct_broker_helpers :rpc (
300
+ Config , NodeA ,
301
+ rabbit_deprecated_features , is_permitted ,
302
+ [ram_node_type ]),
303
+
299
304
ok = rabbit_control_helper :command (stop_app , NodeA ),
300
305
? assertMatch (
301
306
{error , 70 ,
@@ -305,6 +310,12 @@ join_when_ram_node_type_is_permitted_by_default_khepri(Config) ->
305
310
[atom_to_list (NodeB )], [{" --ram" , true }])),
306
311
ok = rabbit_control_helper :command (start_app , NodeA ),
307
312
313
+ ? assertEqual (
314
+ IsPermitted ,
315
+ rabbit_ct_broker_helpers :rpc (
316
+ Config , NodeA ,
317
+ rabbit_deprecated_features , is_permitted , [ram_node_type ])),
318
+
308
319
? assertEqual ([NodeA ], get_all_nodes (Config , NodeA )),
309
320
? assertEqual ([NodeB ], get_all_nodes (Config , NodeB )),
310
321
? assertEqual ([NodeA ], get_disc_nodes (Config , NodeA )),
@@ -357,6 +368,11 @@ join_when_ram_node_type_is_not_permitted_from_conf_khepri(Config) ->
357
368
[NodeA , NodeB ] = rabbit_ct_broker_helpers :get_node_configs (
358
369
Config , nodename ),
359
370
371
+ IsPermitted = rabbit_ct_broker_helpers :rpc (
372
+ Config , NodeA ,
373
+ rabbit_deprecated_features , is_permitted ,
374
+ [ram_node_type ]),
375
+
360
376
ok = rabbit_control_helper :command (stop_app , NodeA ),
361
377
? assertMatch (
362
378
{error , 70 ,
@@ -366,6 +382,12 @@ join_when_ram_node_type_is_not_permitted_from_conf_khepri(Config) ->
366
382
[atom_to_list (NodeB )], [{" --ram" , true }])),
367
383
ok = rabbit_control_helper :command (start_app , NodeA ),
368
384
385
+ ? assertEqual (
386
+ IsPermitted ,
387
+ rabbit_ct_broker_helpers :rpc (
388
+ Config , NodeA ,
389
+ rabbit_deprecated_features , is_permitted , [ram_node_type ])),
390
+
369
391
? assertEqual ([NodeA ], get_all_nodes (Config , NodeA )),
370
392
? assertEqual ([NodeB ], get_all_nodes (Config , NodeB )),
371
393
? assertEqual ([NodeA ], get_disc_nodes (Config , NodeA )),
0 commit comments