@@ -72,6 +72,7 @@ init_per_testcase(TestCase, Config) ->
7272 meck :expect (rabbit_quorum_queue , cancel_consumer_handler , fun (_ , _ ) -> ok end ),
7373 meck :new (rabbit_feature_flags , []),
7474 meck :expect (rabbit_feature_flags , is_enabled , fun (_ ) -> true end ),
75+ meck :expect (rabbit_feature_flags , is_enabled , fun (_ , _ ) -> true end ),
7576 ra_server_sup_sup :remove_all (? RA_SYSTEM ),
7677 ServerName2 = list_to_atom (atom_to_list (TestCase ) ++ " 2" ),
7778 ServerName3 = list_to_atom (atom_to_list (TestCase ) ++ " 3" ),
@@ -880,10 +881,16 @@ discard_next_delivery(ClusterName, State0, Wait) ->
880881 end .
881882
882883start_cluster (ClusterName , ServerIds , RaFifoConfig ) ->
883- {ok , Started , _ } = ra :start_cluster (? RA_SYSTEM ,
884- ClusterName # resource .name ,
885- {module , rabbit_fifo , RaFifoConfig },
886- ServerIds ),
884+ UId = ra :new_uid (ra_lib :to_binary (ClusterName # resource .name )),
885+ Confs = [#{id => Id ,
886+ uid => UId ,
887+ cluster_name => ClusterName # resource .name ,
888+ log_init_args => #{uid => UId },
889+ initial_members => ServerIds ,
890+ initial_machine_version => rabbit_fifo :version (),
891+ machine => {module , rabbit_fifo , RaFifoConfig }}
892+ || Id <- ServerIds ],
893+ {ok , Started , _ } = ra :start_cluster (? RA_SYSTEM , Confs ),
887894 ? assertEqual (length (Started ), length (ServerIds )),
888895 ok .
889896
0 commit comments