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,