diff --git a/main.go b/main.go index d7f7ab3f..182ca33c 100644 --- a/main.go +++ b/main.go @@ -45,8 +45,12 @@ func main() { } chEnv := make(chan *icingadb_ha.Environment) - ha := icingadb_ha.NewHA(&super) - go ha.Run(super.Rdbw, super.Dbw, chEnv, super.ChErr) + ha, err := icingadb_ha.NewHA(&super) + if err != nil { + log.Fatal(err) + } + + go ha.Run(chEnv) go func() { super.ChErr <- icingadb_ha.IcingaEventsBroker(redisConn, chEnv) }()