uppal/cgrates
1
0
Fork 1
mirror of https://github.com/cgrates/cgrates.git synced 2026-02-11 18:16:24 +05:00
Code Issues Packages Projects Releases Wiki Activity

Convert max_reconnect_interval to time.Duration and pass it to the KamEvapi constructor

Browse Source
This commit is contained in:
ionutboangiu
2022-05-20 18:07:00 +03:00
committed by Dan Christian Bogos
parent 4becda2d2a
commit 7790efc7c8
1 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
agents/kamagent.go
View File

@@ -77,7 +77,12 @@ func (self *KamailioAgent) Connect() (err error) {
errChan := make(chan error)
for connIdx, connCfg := range self.cfg.EvapiConns {
logger := log.New(utils.Logger, "kamevapi:", 2)
if self.conns[connIdx], err = kamevapi.NewKamEvapi(connCfg.Address, connIdx, connCfg.Reconnects, eventHandlers, logger); err != nil {
var maxReconnectInterval time.Duration
if maxReconnectInterval, err = utils.ParseDurationWithNanosecs(connCfg.MaxReconnectInterval); err != nil {
return
}
if self.conns[connIdx], err = kamevapi.NewKamEvapi(connCfg.Address, connIdx, connCfg.Reconnects, maxReconnectInterval,
eventHandlers, logger); err != nil {
return
}
utils.Logger.Info(fmt.Sprintf("<%s> successfully connected to Kamailio at: <%s>", utils.KamailioAgent, connCfg.Address))