diff --git a/dispatchers/dispatcher.go b/dispatchers/dispatcher.go
index 9338c5243..ad13d8260 100755
--- a/dispatchers/dispatcher.go
+++ b/dispatchers/dispatcher.go
@@ -99,7 +99,9 @@ func (dS *DispatcherService) authorizeEvent(ev *utils.CGREvent,
 	if dS.attrS == nil {
 		return utils.NewErrNotConnected(utils.AttributeS)
 	}
-	if err = dS.attrS.Call(utils.AttributeSv1ProcessEvent, ev, reply); err != nil {
+	if err = dS.attrS.Call(utils.AttributeSv1ProcessEvent,
+		&engine.AttrArgsProcessEvent{
+			CGREvent: *ev}, reply); err != nil {
 		if err.Error() == utils.ErrNotFound.Error() {
 			err = utils.ErrUnknownApiKey
 		}
diff --git a/engine/cdrs.go b/engine/cdrs.go
index 57754bce2..eac02e7e1 100644
--- a/engine/cdrs.go
+++ b/engine/cdrs.go
@@ -230,7 +230,9 @@ func (self *CdrServer) deriveRateStoreStatsReplicate(cdr *CDR, store, cdrstats,
 			cgrEv := cdrRun.AsCGREvent()
 			cgrEv.Context = utils.StringPointer(utils.MetaCDRs)
 			if err = self.attrS.Call(utils.AttributeSv1ProcessEvent,
-				cgrEv, &rplyEv); err == nil {
+				&AttrArgsProcessEvent{
+					CGREvent: *cgrEv},
+				&rplyEv); err == nil {
 				if err = cdrRun.UpdateFromCGREvent(rplyEv.CGREvent,
 					rplyEv.AlteredFields); err != nil {
 					return
@@ -305,7 +307,8 @@ func (self *CdrServer) deriveCdrs(cdr *CDR) (drvdCDRs []*CDR, err error) {
 	if self.attrS != nil {
 		var rplyEv AttrSProcessEventReply
 		if err = self.attrS.Call(utils.AttributeSv1ProcessEvent,
-			cdr.AsCGREvent(), &rplyEv); err != nil {
+			&AttrArgsProcessEvent{
+				CGREvent: *(cdr.AsCGREvent())}, &rplyEv); err != nil {
 			return
 		}
 		if err = cdr.UpdateFromCGREvent(rplyEv.CGREvent,