diff --git a/engine/cdrs.go b/engine/cdrs.go index a8a56dfe4..66b5515ca 100644 --- a/engine/cdrs.go +++ b/engine/cdrs.go @@ -202,7 +202,7 @@ func (self *CdrServer) processCdr(cdr *CDR) (err error) { } if self.thdS != nil { // process CDR with thresholdS - self.thdSProcessEvent(cdr.AsCGREvent()) + go self.thdSProcessEvent(cdr.AsCGREvent()) } // Attach raw CDR to stats if self.cdrstats != nil { // Send raw CDR to stats