From 834591a155c0e66ac53c0bb0d1d5bb26490907c3 Mon Sep 17 00:00:00 2001
From: Jan Semmelink <jan@uafrica.com>
Date: Mon, 8 Nov 2021 11:30:18 +0200
Subject: [PATCH] Fix bug: must pass loop variable into go routine
---
queues/mem/consumer.go | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/queues/mem/consumer.go b/queues/mem/consumer.go
index f2c3311..317d1dc 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)
}
--
GitLab