Fixed integration test in registrarc

This commit is contained in:
andronache
2021-06-17 08:21:54 +03:00
committed by Dan Christian Bogos
parent dfd179ba4d
commit d39c48377f
2 changed files with 4 additions and 8 deletions

View File

@@ -103,11 +103,6 @@ func (dspS *RegistrarCService) ServiceName() string {
// ShouldRun returns if the service should be running
func (dspS *RegistrarCService) ShouldRun() bool {
if len(dspS.cfg.RegistrarCCfg().RPC.RegistrarSConns) != 0 {
return true
}
if len(dspS.cfg.RegistrarCCfg().Dispatchers.RegistrarSConns) != 0 {
return true
}
return false
return len(dspS.cfg.RegistrarCCfg().RPC.RegistrarSConns) != 0 ||
len(dspS.cfg.RegistrarCCfg().Dispatchers.RegistrarSConns) != 0
}

View File

@@ -89,9 +89,10 @@ func TestDispatcherHReload(t *testing.T) {
if err != nil {
t.Errorf("\nExpecting <nil>,\n Received <%+v>", err)
}
cfg.RegistrarCCfg().RPC.RegistrarSConns = nil
cfg.RegistrarCCfg().Dispatchers.RegistrarSConns = nil
cfg.GetReloadChan(config.RegistrarCJson) <- struct{}{}
time.Sleep(10 * time.Millisecond)
srv.Shutdown()
if srv.IsRunning() {
t.Errorf("Expected service to be down")
}