diff --git a/server/stream.go b/server/stream.go index 9a0031d9..1513c2ff 100644 --- a/server/stream.go +++ b/server/stream.go @@ -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