diff --git a/agents/diamagent.go b/agents/diamagent.go index 72f2fda91..e6c1532f4 100644 --- a/agents/diamagent.go +++ b/agents/diamagent.go @@ -267,7 +267,8 @@ func (da *DiameterAgent) processRequest(reqProcessor *config.RequestProcessor, break } } - cgrArgs := cgrEv.ConsumeArgs(reqProcessor.Flags.HasKey(utils.MetaDispatchers), reqType == utils.MetaAuth || reqType == utils.MetaMessage) + cgrArgs := cgrEv.ConsumeArgs(reqProcessor.Flags.HasKey(utils.MetaDispatchers), + reqType == utils.MetaAuth || reqType == utils.MetaMessage || reqType == utils.MetaEvent) if reqProcessor.Flags.HasKey(utils.MetaLog) { utils.Logger.Info( fmt.Sprintf("<%s> LOG, processorID: %s, diameter message: %s", diff --git a/agents/dnsagent.go b/agents/dnsagent.go index d580b70c4..ee8a2b4f5 100644 --- a/agents/dnsagent.go +++ b/agents/dnsagent.go @@ -170,7 +170,7 @@ func (da *DNSAgent) processRequest(reqProcessor *config.RequestProcessor, } } cgrArgs := cgrEv.ConsumeArgs(reqProcessor.Flags.HasKey(utils.MetaDispatchers), - reqType == utils.MetaAuth || reqType == utils.MetaMessage) + reqType == utils.MetaAuth || reqType == utils.MetaMessage || reqType == utils.MetaEvent) if reqProcessor.Flags.HasKey(utils.MetaLog) { utils.Logger.Info( fmt.Sprintf("<%s> LOG, processorID: <%s>, message: %s", diff --git a/agents/httpagent.go b/agents/httpagent.go index a11d38109..0cdd6fb0a 100644 --- a/agents/httpagent.go +++ b/agents/httpagent.go @@ -117,7 +117,8 @@ func (ha *HTTPAgent) processRequest(reqProcessor *config.RequestProcessor, break } } - cgrArgs := cgrEv.ConsumeArgs(reqProcessor.Flags.HasKey(utils.MetaDispatchers), reqType == utils.MetaAuth || reqType == utils.MetaMessage) + cgrArgs := cgrEv.ConsumeArgs(reqProcessor.Flags.HasKey(utils.MetaDispatchers), + reqType == utils.MetaAuth || reqType == utils.MetaMessage || reqType == utils.MetaEvent) if reqProcessor.Flags.HasKey(utils.MetaLog) { utils.Logger.Info( fmt.Sprintf("<%s> LOG, processorID: %s, http message: %s", diff --git a/agents/radagent.go b/agents/radagent.go index a9f367670..f8b15593a 100644 --- a/agents/radagent.go +++ b/agents/radagent.go @@ -163,7 +163,8 @@ func (ra *RadiusAgent) processRequest(reqProcessor *config.RequestProcessor, break } } - cgrArgs := cgrEv.ConsumeArgs(reqProcessor.Flags.HasKey(utils.MetaDispatchers), reqType == utils.MetaAuth || reqType == utils.MetaMessage) + cgrArgs := cgrEv.ConsumeArgs(reqProcessor.Flags.HasKey(utils.MetaDispatchers), + reqType == utils.MetaAuth || reqType == utils.MetaMessage || reqType == utils.MetaEvent) if reqProcessor.Flags.HasKey(utils.MetaLog) { utils.Logger.Info( fmt.Sprintf("<%s> LOG, processorID: %s, radius message: %s",