fix possible race condition in rmq initialization

pace · Jul 6, 2020 · c095beb · c095beb
1 parent 3f73bc7
commit c095beb
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/backend/queue/rmq.go b/backend/queue/rmq.go
@@ -14,12 +14,18 @@ import (
 var (
 	rmqConnection     rmq.Connection
 	queueHealthLimits sync.Map
+
+	initMutex sync.Mutex
 )
 
 func initDefault() {
+	initMutex.Lock()
+	defer initMutex.Unlock()
+
 	if rmqConnection != nil {
 		return
 	}
+
 	rmqConnection = rmq.OpenConnectionWithRedisClient("default", redis.Client())
 	gatherMetrics(rmqConnection)
 	servicehealthcheck.RegisterHealthCheck("rmq", &HealthCheck{})