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))