diff --git a/modules/queue/setting.go b/modules/queue/setting.go index 786a08a3b..35c33aeac 100644 --- a/modules/queue/setting.go +++ b/modules/queue/setting.go @@ -43,6 +43,7 @@ func getQueueSettings(name string) (setting.QueueSettings, []byte) { opts["BlockTimeout"] = q.BlockTimeout opts["BoostTimeout"] = q.BoostTimeout opts["BoostWorkers"] = q.BoostWorkers + opts["ConnectionString"] = q.ConnectionString cfg, err := json.Marshal(opts) if err != nil {