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

Add Kamailio agent session restoration support

Browse Source
This commit is contained in:
arberkatellari
2024-07-02 14:25:29 +02:00
committed by Dan Christian Bogos
parent 5ccb77c5dc
commit 7fa3249d54
1 changed files with 5 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
agents/kamagent.go
View File

@@ -81,6 +81,11 @@ func (self *KamailioAgent) Connect() (err error) {
kamProcessMessageRegex: {self.onCgrProcessMessage},
kamProcessCDRRegex: {self.onCgrProcessCDR},
}
var reply string
// make a call kamailio_agent -> sessions_conns to create an active client needed for syncSessions when restoring sessions, since prior clients are lost when engine shuts down
if err := self.connMgr.Call(self.ctx, self.cfg.SessionSConns, utils.SessionSv1Ping, &utils.CGREvent{}, &reply); err != nil {
return err
}
errChan := make(chan error)
for connIdx, connCfg := range self.cfg.EvapiConns {
if self.conns[connIdx], err = kamevapi.NewKamEvapi(connCfg.Address, connIdx, connCfg.Reconnects, connCfg.MaxReconnectInterval,