From 0edb70a099262efe9bf4521dc4d5ae4ce71622c4 Mon Sep 17 00:00:00 2001
From: Andrew Thornton <art27@cantab.net>
Date: Sat, 7 Dec 2019 16:41:53 +0000
Subject: [PATCH] Queue: Add worker settings

---
 modules/setting/queue.go | 11 ++++++++++-
 1 file changed, 10 insertions(+), 1 deletion(-)

diff --git a/modules/setting/queue.go b/modules/setting/queue.go
index 4f7da32ce9..1a33e232c3 100644
--- a/modules/setting/queue.go
+++ b/modules/setting/queue.go
@@ -119,7 +119,16 @@ func newQueueService() {
 	Queue.Timeout = sec.Key("TIMEOUT").MustDuration(GracefulHammerTime + 30*time.Second)
 	Queue.Workers = sec.Key("WORKER").MustInt(1)
 
-	Cfg.Section("queue.notification").Key("WORKER").MustInt(5)
+	hasWorkers := false
+	for _, key := range Cfg.Section("queue.notification").Keys() {
+		if key.Name() == "WORKERS" {
+			hasWorkers = true
+			break
+		}
+	}
+	if !hasWorkers {
+		Cfg.Section("queue.notification").Key("WORKERS").SetValue("5")
+	}
 }
 
 // ParseQueueConnStr parses a queue connection string