This commit is contained in:
Andrew Thornton
2019-12-30 18:38:57 +00:00
parent cc123c3448
commit 1013ced326
4 changed files with 12 additions and 6 deletions
+3 -1
View File
@@ -115,7 +115,9 @@ func getQueueSettings(name string) queueSettings {
return q
}
func newQueueService() {
// NewQueueService sets up the default settings for Queues
// This is exported for tests to be able to use the queue
func NewQueueService() {
sec := Cfg.Section("queue")
Queue.DataDir = sec.Key("DATADIR").MustString("queues/")
if !path.IsAbs(Queue.DataDir) {
+1 -1
View File
@@ -1090,5 +1090,5 @@ func NewServices() {
newMigrationsService()
newIndexerService()
newTaskService()
newQueueService()
NewQueueService()
}