From 5e7b648012a48cf77d8be7c4ed9e586b8199b0cb Mon Sep 17 00:00:00 2001 From: TeoV Date: Fri, 9 Oct 2020 16:47:45 +0300 Subject: [PATCH] Add better logs when start diffent Agents --- agents/astagent.go | 2 ++ agents/kamagent.go | 1 + services/httpagent.go | 3 ++- 3 files changed, 5 insertions(+), 1 deletion(-) diff --git a/agents/astagent.go b/agents/astagent.go index 1e192ab71..2cd8c016f 100644 --- a/agents/astagent.go +++ b/agents/astagent.go @@ -97,6 +97,8 @@ func (sma *AsteriskAgent) ListenAndServe() (err error) { if err = sma.connectAsterisk(); err != nil { return } + utils.Logger.Info(fmt.Sprintf("<%s> successfully connected to Asterisk at: <%s>", + utils.AsteriskAgent, sma.cgrCfg.AsteriskAgentCfg().AsteriskConns[sma.astConnIdx].Address)) for { select { case err = <-sma.astErrChan: diff --git a/agents/kamagent.go b/agents/kamagent.go index f7f866000..d704734cd 100644 --- a/agents/kamagent.go +++ b/agents/kamagent.go @@ -79,6 +79,7 @@ func (self *KamailioAgent) Connect() (err error) { if self.conns[connIdx], err = kamevapi.NewKamEvapi(connCfg.Address, connIdx, connCfg.Reconnects, eventHandlers, logger); err != nil { return } + utils.Logger.Info(fmt.Sprintf("<%s> successfully connected to Kamailio at: <%s>", utils.KamAgentCfg, connCfg.Address)) go func(conn *kamevapi.KamEvapi) { // Start reading in own goroutine, return on error if err := conn.ReadEvents(); err != nil { errChan <- err diff --git a/services/httpagent.go b/services/httpagent.go index 62c64b3aa..fc4390eb1 100644 --- a/services/httpagent.go +++ b/services/httpagent.go @@ -19,6 +19,7 @@ along with this program. If not, see package services import ( + "fmt" "sync" "github.com/cgrates/cgrates/agents" @@ -61,7 +62,7 @@ func (ha *HTTPAgent) Start() (err error) { ha.Lock() defer ha.Unlock() - utils.Logger.Info("Starting HTTP agent") + utils.Logger.Info(fmt.Sprintf("<%s> successfully started HTTPAgent", utils.HttpAgentCfg)) for _, agntCfg := range ha.cfg.HttpAgentCfg() { ha.server.RegisterHttpHandler(agntCfg.Url, agents.NewHTTPAgent(ha.connMgr, agntCfg.SessionSConns, filterS,