diff --git a/ers/filecsv.go b/ers/filecsv.go index a5bc5a50d..8efa82c97 100644 --- a/ers/filecsv.go +++ b/ers/filecsv.go @@ -139,7 +139,7 @@ func (rdr *CSVFileER) processFile(fPath, fName string) (err error) { rowNr := 0 // This counts the rows in the file, not really number of CDRs evsPosted := 0 timeStart := time.Now() - reqVars := utils.NavigableMap2{utils.FileName: utils.NewNMData(fName)} + reqVars := utils.NavigableMap2{utils.MetaFileName: utils.NewNMData(fName)} for { var record []string if record, err = csvReader.Read(); err != nil { diff --git a/ers/filefwv.go b/ers/filefwv.go index 5f0488d02..d5fc49b9e 100644 --- a/ers/filefwv.go +++ b/ers/filefwv.go @@ -139,7 +139,7 @@ func (rdr *FWVFileER) processFile(fPath, fName string) (err error) { rowNr := 0 // This counts the rows in the file, not really number of CDRs evsPosted := 0 timeStart := time.Now() - reqVars := utils.NavigableMap2{utils.FileName: utils.NewNMData(fName)} + reqVars := utils.NavigableMap2{utils.MetaFileName: utils.NewNMData(fName)} for { var hasHeader, hasTrailer bool diff --git a/ers/filexml.go b/ers/filexml.go index 3af312f21..a1443f31e 100644 --- a/ers/filexml.go +++ b/ers/filexml.go @@ -137,7 +137,7 @@ func (rdr *XMLFileER) processFile(fPath, fName string) (err error) { rowNr := 0 // This counts the rows in the file, not really number of CDRs evsPosted := 0 timeStart := time.Now() - reqVars := utils.NavigableMap2{utils.FileName: utils.NewNMData(fName)} + reqVars := utils.NavigableMap2{utils.MetaFileName: utils.NewNMData(fName)} for _, xmlElmt := range xmlElmts { rowNr++ // increment the rowNr after checking if it's not the end of file agReq := agents.NewAgentRequest( diff --git a/ers/flatstore.go b/ers/flatstore.go index 59dff63a8..add5b61b5 100644 --- a/ers/flatstore.go +++ b/ers/flatstore.go @@ -146,7 +146,7 @@ func (rdr *FlatstoreER) processFile(fPath, fName string) (err error) { rowNr := 0 // This counts the rows in the file, not really number of CDRs evsPosted := 0 timeStart := time.Now() - reqVars := utils.NavigableMap2{utils.FileName: utils.NewNMData(fName)} + reqVars := utils.NavigableMap2{utils.MetaFileName: utils.NewNMData(fName)} for { var record []string if record, err = csvReader.Read(); err != nil { diff --git a/ers/partial_csv.go b/ers/partial_csv.go index 00e2ff9c5..afad29f25 100644 --- a/ers/partial_csv.go +++ b/ers/partial_csv.go @@ -153,7 +153,7 @@ func (rdr *PartialCSVFileER) processFile(fPath, fName string) (err error) { rowNr := 0 // This counts the rows in the file, not really number of CDRs evsPosted := 0 timeStart := time.Now() - reqVars := utils.NavigableMap2{utils.FileName: utils.NewNMData(fName)} + reqVars := utils.NavigableMap2{utils.MetaFileName: utils.NewNMData(fName)} for { var record []string if record, err = csvReader.Read(); err != nil { diff --git a/utils/consts.go b/utils/consts.go index f5a9b76ed..7bff91b4d 100755 --- a/utils/consts.go +++ b/utils/consts.go @@ -665,7 +665,7 @@ const ( MetaDiamreq = "*diamreq" MetaGroup = "*group" InternalRPCSet = "InternalRPCSet" - FileName = "FileName" + MetaFileName = "*fileName" MetaBusy = "*busy" MetaQueue = "*queue" MetaRounding = "*rounding"