aboutsummaryrefslogtreecommitdiffstats
path: root/modules/setting/queue.go
diff options
context:
space:
mode:
Diffstat (limited to 'modules/setting/queue.go')
-rw-r--r--modules/setting/queue.go6
1 files changed, 3 insertions, 3 deletions
diff --git a/modules/setting/queue.go b/modules/setting/queue.go
index c626f585f0..41e95fbe5a 100644
--- a/modules/setting/queue.go
+++ b/modules/setting/queue.go
@@ -48,7 +48,7 @@ func GetQueueSettings(name string) QueueSettings {
q.Name = name
// DataDir is not directly inheritable
- q.DataDir = filepath.Join(Queue.DataDir, "common")
+ q.DataDir = filepath.ToSlash(filepath.Join(Queue.DataDir, "common"))
// QueueName is not directly inheritable either
q.QueueName = name + Queue.QueueName
for _, key := range sec.Keys() {
@@ -91,9 +91,9 @@ func GetQueueSettings(name string) QueueSettings {
// 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/")
+ Queue.DataDir = filepath.ToSlash(sec.Key("DATADIR").MustString("queues/"))
if !filepath.IsAbs(Queue.DataDir) {
- Queue.DataDir = filepath.Join(AppDataPath, Queue.DataDir)
+ Queue.DataDir = filepath.ToSlash(filepath.Join(AppDataPath, Queue.DataDir))
}
Queue.QueueLength = sec.Key("LENGTH").MustInt(20)
Queue.BatchLength = sec.Key("BATCH_LENGTH").MustInt(20)