From 7790efc7c87b2d49fc17361e5a53ee0ba835ec31 Mon Sep 17 00:00:00 2001 From: ionutboangiu Date: Fri, 20 May 2022 18:07:00 +0300 Subject: [PATCH] Convert max_reconnect_interval to time.Duration and pass it to the KamEvapi constructor --- agents/kamagent.go | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/agents/kamagent.go b/agents/kamagent.go index 8659ba76d..2ee041a78 100644 --- a/agents/kamagent.go +++ b/agents/kamagent.go @@ -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))