diff --git a/queues/mem/consumer.go b/queues/mem/consumer.go
index f2c33116343fc1f61fca466b4d4e5d7c8234ef1b..317d1dc33622fc5e4f3377c3cd139252c69b8f8c 100644
--- a/queues/mem/consumer.go
+++ b/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)
 }