Skip to content

Commit 579dea8

Browse files
committed
bugfix: set wrong Ttr by Queue.Cfg()
Ttr should be in seconds. Part of #278
1 parent 21123d2 commit 579dea8

File tree

2 files changed

+2
-1
lines changed

2 files changed

+2
-1
lines changed

CHANGELOG.md

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -27,6 +27,7 @@ Versioning](http://semver.org/spec/v2.0.0.html) except to the first release.
2727
set (#272)
2828
- Watcher events loss with a small per-request timeout (#284)
2929
- Connect() panics on concurrent schema update (#278)
30+
- Wrong Ttr setup by Queue.Cfg() (#278)
3031

3132
## [1.10.0] - 2022-12-31
3233

queue/queue.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -143,7 +143,7 @@ func (opts CfgOpts) toMap() map[string]interface{} {
143143
ret := make(map[string]interface{})
144144
ret["in_replicaset"] = opts.InReplicaset
145145
if opts.Ttr != 0 {
146-
ret["ttr"] = opts.Ttr
146+
ret["ttr"] = opts.Ttr.Seconds()
147147
}
148148
return ret
149149
}

0 commit comments

Comments
 (0)