diff --git a/agents/astagent.go b/agents/astagent.go
index 1662ec709..e475079fc 100644
--- a/agents/astagent.go
+++ b/agents/astagent.go
@@ -304,7 +304,8 @@ func (sma *AsteriskAgent) handleChannelDestroyed(ev *SMAsteriskEvent) {
 			utils.AsteriskAgent, err.Error(), ev.ChannelID()))
 	}
 	if sma.cgrCfg.AsteriskAgentCfg().CreateCDR {
-		if err := sma.smg.Call(utils.SessionSv1ProcessCDR, cgrEv, &reply); err != nil {
+		if err := sma.smg.Call(utils.SessionSv1ProcessCDR,
+			&utils.CGREventWithArgDispatcher{CGREvent: cgrEv}, &reply); err != nil {
 			utils.Logger.Err(fmt.Sprintf("<%s> Error: %s when attempting to process CDR for channelID: %s",
 				utils.AsteriskAgent, err.Error(), ev.ChannelID()))
 		}
diff --git a/agents/fsagent.go b/agents/fsagent.go
index 7766b1279..aa3c3e9ef 100644
--- a/agents/fsagent.go
+++ b/agents/fsagent.go
@@ -265,7 +265,8 @@ func (sm *FSsessions) onChannelHangupComplete(fsev FSEvent, connId string) {
 		if err != nil {
 			return
 		}
-		if err := sm.sS.Call(utils.SessionSv1ProcessCDR, cgrEv, &reply); err != nil {
+		if err := sm.sS.Call(utils.SessionSv1ProcessCDR,
+			&utils.CGREventWithArgDispatcher{CGREvent: cgrEv}, &reply); err != nil {
 			utils.Logger.Err(fmt.Sprintf("<%s> Failed processing CGREvent: %s,  error: <%s>",
 				utils.FreeSWITCHAgent, utils.ToJSON(cgrEv), err.Error()))
 		}
diff --git a/agents/httpagent.go b/agents/httpagent.go
index 5a04aa7c7..05202f5f8 100644
--- a/agents/httpagent.go
+++ b/agents/httpagent.go
@@ -205,7 +205,7 @@ func (ha *HTTPAgent) processRequest(reqProcessor *config.HttpAgntProcCfg,
 		!reqProcessor.Flags.HasKey(utils.MetaDryRun) {
 		var rplyCDRs string
 		if err = ha.sessionS.Call(utils.SessionSv1ProcessCDR,
-			cgrEv, &rplyCDRs); err != nil {
+			&utils.CGREventWithArgDispatcher{CGREvent: cgrEv}, &rplyCDRs); err != nil {
 			agReq.CGRReply.Set([]string{utils.Error}, err.Error(), false, false)
 		}
 	}
diff --git a/agents/kamagent.go b/agents/kamagent.go
index d556dc1bc..e9f170f76 100644
--- a/agents/kamagent.go
+++ b/agents/kamagent.go
@@ -200,7 +200,8 @@ func (ka *KamailioAgent) onCallEnd(evData []byte, connID string) {
 			return
 		}
 		cgrEv.Event[utils.OriginHost] = ka.conns[connID].RemoteAddr().String()
-		if err := ka.sessionS.Call(utils.SessionSv1ProcessCDR, cgrEv, &reply); err != nil {
+		if err := ka.sessionS.Call(utils.SessionSv1ProcessCDR,
+			&utils.CGREventWithArgDispatcher{CGREvent: cgrEv}, &reply); err != nil {
 			utils.Logger.Err(fmt.Sprintf("%s> failed processing CGREvent: %s, error: %s",
 				utils.KamailioAgent, utils.ToJSON(cgrEv), err.Error()))
 		}