Fix bug that would race around check for last sequence per subject

Signed-off-by: Derek Collison <derek@nats.io>
nats-io · Jul 18, 2023 · 244dda8 · 244dda8
1 parent 360f807
commit 244dda8
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/server/stream.go b/server/stream.go
@@ -3838,7 +3838,7 @@ func (mset *stream) processJetStreamMsg(subject, reply string, hdr, msg []byte,
 		}
 		// Expected last sequence per subject.
 		// If we are clustered we have prechecked seq > 0.
-		if seq, exists := getExpectedLastSeqPerSubject(hdr); exists && (!isClustered || seq == 0) {
+		if seq, exists := getExpectedLastSeqPerSubject(hdr); exists {
 			// TODO(dlc) - We could make a new store func that does this all in one.
 			var smv StoreMsg
 			var fseq uint64