Fix bug: must pass loop variable into go routine

queues/mem/consumer.go

@@ -116,7 +116,7 @@ func (q *queue) run() {
 	// logger.Debugf("Q(%s) Start", q.name)
 	for event := range q.ch {
 		//process in background because some event processing sends to itself then wait for some responses on new events on the same queue!!!
-		go func() {
+		go func(event service.Event) {
 			// logger.Debugf("Q(%s) process start: %+v", q.name, event)
 			err := q.process(event)
 			if err != nil {
@@ -124,7 +124,7 @@ func (q *queue) run() {
 				// } else {
 				// 	q.consumer.Debugf("Q(%s) process success: %+v", q.name, err)
 			}
-		}()
+		}(event)
 	}
 	// logger.Debugf("Q(%s) STOPPED", q.name)
 }