@@ -942,14 +942,17 @@ discard_next_delivery(ClusterName, State0, Wait) ->
942
942
end .
943
943
944
944
start_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
953
956
|| Id <- ServerIds ],
954
957
{ok , Started , _ } = ra :start_cluster (? RA_SYSTEM , Confs ),
955
958
? assertEqual (length (Started ), length (ServerIds )),
0 commit comments