From bd96dd2fa09a50d16ebcc02a6235b3bc9c2c51fe Mon Sep 17 00:00:00 2001 From: ionutboangiu Date: Fri, 20 May 2022 17:11:24 +0300 Subject: [PATCH] Convert max_reconnect_interval to time.Duration and pass it to the ARInGO constructor --- agents/astagent.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/agents/astagent.go b/agents/astagent.go index 3b8418ea5..2bfc29502 100644 --- a/agents/astagent.go +++ b/agents/astagent.go @@ -83,10 +83,14 @@ func (sma *AsteriskAgent) connectAsterisk(stopChan <-chan struct{}) (err error) connCfg := sma.cgrCfg.AsteriskAgentCfg().AsteriskConns[sma.astConnIdx] sma.astEvChan = make(chan map[string]interface{}) sma.astErrChan = make(chan error) + var maxReconnectInterval time.Duration + if maxReconnectInterval, err = utils.ParseDurationWithNanosecs(connCfg.MaxReconnectInterval); err != nil { + return + } sma.astConn, err = aringo.NewARInGO(fmt.Sprintf("ws://%s/ari/events?api_key=%s:%s&app=%s", connCfg.Address, connCfg.User, connCfg.Password, CGRAuthAPP), "http://cgrates.org", connCfg.User, connCfg.Password, fmt.Sprintf("%s@%s", utils.CGRateS, utils.Version), - sma.astEvChan, sma.astErrChan, stopChan, connCfg.ConnectAttempts, connCfg.Reconnects) + sma.astEvChan, sma.astErrChan, stopChan, connCfg.ConnectAttempts, connCfg.Reconnects, maxReconnectInterval) return }