mirror of
https://github.com/gogrlx/nats-server.git
synced 2026-04-16 11:04:42 -07:00
Don't forget last message
Signed-off-by: Derek Collison <derek@nats.io>
This commit is contained in:
@@ -4274,7 +4274,7 @@ func (mset *stream) runCatchup(sendSubject string, sreq *streamSyncRequest) {
|
||||
notActive.Reset(activityInterval)
|
||||
sendNextBatch()
|
||||
// Check if we are finished.
|
||||
if seq >= last {
|
||||
if seq > last {
|
||||
s.Debugf("Done resync for stream '%s > %s'", mset.account(), mset.name())
|
||||
return
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user