diff --git a/cmd/cgr-engine/cgr-engine.go b/cmd/cgr-engine/cgr-engine.go index 0fc67d5e7..d166a6fe2 100644 --- a/cmd/cgr-engine/cgr-engine.go +++ b/cmd/cgr-engine/cgr-engine.go @@ -163,8 +163,8 @@ func startRPC(server *cores.Server, internalAdminSChan, internalAdminSChan <- admS case attrS := <-internalAttrSChan: internalAttrSChan <- attrS - // case chrgS := <-internalChargerSChan: - // internalChargerSChan <- chrgS + case chrgS := <-internalChargerSChan: + internalChargerSChan <- chrgS case thS := <-internalThdSChan: internalThdSChan <- thS case rtS := <-internalRouteSChan: diff --git a/services/cores_test.go b/services/cores_test.go index f9a5d8506..82a6146f1 100644 --- a/services/cores_test.go +++ b/services/cores_test.go @@ -41,7 +41,7 @@ func TestCoreSCoverage(t *testing.T) { srvDep := map[string]*sync.WaitGroup{utils.DataDB: new(sync.WaitGroup)} anz := NewAnalyzerService(cfg, server, filterSChan, shdChan, make(chan birpc.ClientConnector, 1), srvDep) srv := NewCoreService(cfg, caps, server, - internalCoreSChan, anz, srvDep, shdChan) + internalCoreSChan, anz, nil, srvDep, shdChan) if srv == nil { t.Errorf("\nExpecting ,\n Received <%+v>", utils.ToJSON(srv)) }