diff --git a/CHANGELOG.md b/CHANGELOG.md index 5f1861883..d5fe188b5 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -27,6 +27,7 @@ Versioning](http://semver.org/spec/v2.0.0.html) except to the first release. set (#272) - Watcher events loss with a small per-request timeout (#284) - Connect() panics on concurrent schema update (#278) +- Wrong Ttr setup by Queue.Cfg() (#278) ## [1.10.0] - 2022-12-31 diff --git a/queue/queue.go b/queue/queue.go index df13f09bb..8d161b033 100644 --- a/queue/queue.go +++ b/queue/queue.go @@ -143,7 +143,7 @@ func (opts CfgOpts) toMap() map[string]interface{} { ret := make(map[string]interface{}) ret["in_replicaset"] = opts.InReplicaset if opts.Ttr != 0 { - ret["ttr"] = opts.Ttr + ret["ttr"] = opts.Ttr.Seconds() } return ret }