@@ -942,14 +942,17 @@ discard_next_delivery(ClusterName, State0, Wait) ->
942942 end .
943943
944944start_cluster (ClusterName , ServerIds , RaFifoConfig ) ->
945- UId = ra :new_uid (ra_lib :to_binary (ClusterName # resource .name )),
946- Confs = [#{id => Id ,
947- uid => UId ,
948- cluster_name => ClusterName # resource .name ,
949- log_init_args => #{uid => UId },
950- initial_members => ServerIds ,
951- initial_machine_version => rabbit_fifo :version (),
952- machine => {module , rabbit_fifo , RaFifoConfig }}
945+ NameBin = ra_lib :to_binary (ClusterName # resource .name ),
946+ Confs = [begin
947+ UId = ra :new_uid (NameBin ),
948+ #{id => Id ,
949+ uid => UId ,
950+ cluster_name => ClusterName # resource .name ,
951+ log_init_args => #{uid => UId },
952+ initial_members => ServerIds ,
953+ initial_machine_version => rabbit_fifo :version (),
954+ machine => {module , rabbit_fifo , RaFifoConfig }}
955+ end
953956 || Id <- ServerIds ],
954957 {ok , Started , _ } = ra :start_cluster (? RA_SYSTEM , Confs ),
955958 ? assertEqual (length (Started ), length (ServerIds )),
0 commit comments