gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-17 03:24:40 -07:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'main' into dev

Browse Source
This commit is contained in:
Derek Collison
2022-11-15 08:01:51 -08:00
parent 095b13c4be c94a260c97
commit c83d5ce4c6
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
server/consumer.go
View File

@@ -749,7 +749,9 @@ func (mset *stream) addConsumerWithAssignment(config *ConsumerConfig, oname stri
if o.store != nil && o.store.HasState() {
// Restore our saved state.
o.mu.Lock()
o.readStoredState(0)
o.mu.Unlock()
} else {
// Select starting sequence number
o.selectStartingSeqNo()