Merge pull request #2712 from nats-io/issue-2708

[FIXED #2708] Removing a source depending on timing could cause a server panic.
This commit is contained in:
Derek Collison
2021-11-29 13:26:18 -08:00
committed by GitHub

View File

@@ -1787,6 +1787,9 @@ func (mset *stream) setSourceConsumer(iname string, seq uint64) {
si.sseq, si.dseq = seq, 0
si.last = time.Now()
ssi := mset.streamSource(iname)
if ssi == nil {
return
}
// Determine subjects etc.
var deliverSubject string