diff --git a/cmd/cgr-engine/cgr-engine.go b/cmd/cgr-engine/cgr-engine.go
index db3278f93..562a58cde 100644
--- a/cmd/cgr-engine/cgr-engine.go
+++ b/cmd/cgr-engine/cgr-engine.go
@@ -330,8 +330,8 @@ func main() {
 	stopHandled := false
 	// Async starts here
 	if cfg.RaterEnabled && cfg.RaterBalancer != "" && !cfg.BalancerEnabled {
-		registerToBalancer()
-		stopRaterSignalHandler()
+		go registerToBalancer()
+		go stopRaterSignalHandler()
 		stopHandled = true
 	}
 	responder := &engine.Responder{ExitChan: exitChan}
@@ -361,7 +361,7 @@ func main() {
 		engine.Logger.Info("Starting CGRateS Scheduler.")
 		go func() {
 			sched := scheduler.NewScheduler()
-			reloadSchedulerSingnalHandler(sched, accountDb)
+			go reloadSchedulerSingnalHandler(sched, accountDb)
 			apier.Sched = sched
 			sched.LoadActionTimings(accountDb)
 			sched.Loop()
@@ -370,28 +370,28 @@ func main() {
 
 	if cfg.SMEnabled {
 		engine.Logger.Info("Starting CGRateS SessionManager.")
-		startSessionManager(responder, logDb)
+		go startSessionManager(responder, logDb)
 		// close all sessions on shutdown
-		shutdownSessionmanagerSingnalHandler()
+		go shutdownSessionmanagerSingnalHandler()
 	}
 
 	if cfg.MediatorEnabled {
 		engine.Logger.Info("Starting CGRateS Mediator.")
-		startMediator(responder, logDb, cdrDb)
+		go startMediator(responder, logDb, cdrDb)
 	}
 
 	if cfg.CDRSEnabled {
 		engine.Logger.Info("Starting CGRateS CDR Server.")
-		startCDRS(responder, cdrDb)
+		go startCDRS(responder, cdrDb)
 	}
 
 	if cfg.HistoryServerEnabled || cfg.HistoryAgentEnabled {
 		engine.Logger.Info("Starting History Service.")
-		startHistoryScribe()
+		go startHistoryScribe()
 	}
 	if cfg.CdrcEnabled {
 		engine.Logger.Info("Starting CGRateS CDR Client.")
-		startCdrc()
+		go startCdrc()
 	}
 	go server.ServeGOB(cfg.RPCGOBListen)
 	go server.ServeJSON(cfg.RPCJSONListen)
diff --git a/engine/server.go b/engine/server.go
index 091c5de55..b05221fed 100644
--- a/engine/server.go
+++ b/engine/server.go
@@ -58,11 +58,11 @@ func (s *Server) ServeJSON(addr string) {
 	for {
 		conn, err := lJSON.Accept()
 		if err != nil {
-			Logger.Err(fmt.Sprintf("<History> Accept error: %v", conn))
+			Logger.Err(fmt.Sprintf("<CGRServer> Accept error: %v", conn))
 			continue
 		}
 
-		Logger.Info(fmt.Sprintf("<History> New incoming connection: %v", conn.RemoteAddr()))
+		//Logger.Info(fmt.Sprintf("<CGRServer> New incoming connection: %v", conn.RemoteAddr()))
 		go jsonrpc.ServeConn(conn)
 	}
 
@@ -79,11 +79,11 @@ func (s *Server) ServeGOB(addr string) {
 	for {
 		conn, err := lGOB.Accept()
 		if err != nil {
-			Logger.Err(fmt.Sprintf("<History> Accept error: %v", conn))
+			Logger.Err(fmt.Sprintf("<CGRServer> Accept error: %v", conn))
 			continue
 		}
 
-		Logger.Info(fmt.Sprintf("<History> New incoming connection: %v", conn.RemoteAddr()))
+		//Logger.Info(fmt.Sprintf("<CGRServer> New incoming connection: %v", conn.RemoteAddr()))
 		go rpc.ServeConn(conn)
 	}
 }