Skip to content

Commit dc8c604

Browse files
committed
bugfix: set wrong Ttr by Queue.Cfg()
Ttr should be in seconds. Part of #278
1 parent 1716de6 commit dc8c604

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
@@ -26,6 +26,7 @@ Versioning](http://semver.org/spec/v2.0.0.html) except to the first release.
2626
- ConnectionPool does not properly handle disconnection with Opts.Reconnect
2727
set (#272)
2828
- Connect() panics on concurrent schema update (#278)
29+
- Wrong Ttr setup by Queue.Cfg() (#278)
2930

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

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)