diff --git a/main.go b/main.go index 0be6676..7322eab 100644 --- a/main.go +++ b/main.go @@ -103,6 +103,7 @@ func StartNode(replicaID uint64, exampleShardID uint64, addr string) *dragonboat if err != nil { panic(err) } + if err := nh.StartReplica(initialMembers, false, NewSMQueue, rc); err != nil { fmt.Fprintf(os.Stderr, "failed to add cluster, %v\n", err) os.Exit(1)