Missed setting ConnectionString on queuesettings Signed-off-by: Andrew Thornton <art27@cantab.net>
This commit is contained in:
parent
feb1a8cabc
commit
5cfc1f573f
1 changed files with 1 additions and 0 deletions
|
@ -43,6 +43,7 @@ func getQueueSettings(name string) (setting.QueueSettings, []byte) {
|
||||||
opts["BlockTimeout"] = q.BlockTimeout
|
opts["BlockTimeout"] = q.BlockTimeout
|
||||||
opts["BoostTimeout"] = q.BoostTimeout
|
opts["BoostTimeout"] = q.BoostTimeout
|
||||||
opts["BoostWorkers"] = q.BoostWorkers
|
opts["BoostWorkers"] = q.BoostWorkers
|
||||||
|
opts["ConnectionString"] = q.ConnectionString
|
||||||
|
|
||||||
cfg, err := json.Marshal(opts)
|
cfg, err := json.Marshal(opts)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
|
Reference in a new issue