diff --git a/ees/rpc.go b/ees/rpc.go
index 1050beb92..4f70518f8 100644
--- a/ees/rpc.go
+++ b/ees/rpc.go
@@ -62,13 +62,9 @@ func (e *RPCee) Cfg() (eCfg *config.EventExporterCfg) {
 
 func (e *RPCee) Connect() (err error) {
 	e.Lock()
-	if e.conn != nil {
-		var conn *rpcclient.RPCClient
-		conn, err = rpcclient.NewRPCClient(context.TODO(), utils.TCP, e.cfg.ExportPath, e.tls,
-			e.keyPath, e.certPath, e.caPath, 1, 1, e.connTimeout, e.replyTimeout, e.codec, nil, false, nil)
-		if err == nil {
-			e.conn = conn
-		}
+	if e.conn, err = rpcclient.NewRPCClient(context.TODO(), utils.TCP, e.cfg.ExportPath, e.tls,
+		e.keyPath, e.certPath, e.caPath, 1, 1, e.connTimeout, e.replyTimeout, e.codec, nil, false, nil); err != nil {
+		return
 	}
 	e.Unlock()
 	return
diff --git a/services/cgr-engine.go b/services/cgr-engine.go
index a4dfa2b82..ac77daa56 100644
--- a/services/cgr-engine.go
+++ b/services/cgr-engine.go
@@ -119,10 +119,6 @@ func (cgr *CGREngine) GetServDeps() map[string]*sync.WaitGroup {
 	return cgr.srvDep
 }
 
-func (cgr *CGREngine) GetDbService() *DataDBService {
-	return cgr.dmS
-}
-
 func (cgr *CGREngine) AddService(service servmanager.Service, connName, apiPrefix string,
 	iConnCh chan birpc.ClientConnector) {
 	cgr.srvManager.AddServices(service)