diff --git a/server/stream.go b/server/stream.go index f8c345e0..3e2e730b 100644 --- a/server/stream.go +++ b/server/stream.go @@ -4485,7 +4485,7 @@ func (mset *stream) delete() error { // Internal function to stop or delete the stream. func (mset *stream) stop(deleteFlag, advisory bool) error { mset.mu.RLock() - js, jsa := mset.js, mset.jsa + js, jsa, name := mset.js, mset.jsa, mset.cfg.Name mset.mu.RUnlock() if jsa == nil { @@ -4494,7 +4494,7 @@ func (mset *stream) stop(deleteFlag, advisory bool) error { // Remove from our account map first. jsa.mu.Lock() - delete(jsa.streams, mset.cfg.Name) + delete(jsa.streams, name) accName := jsa.account.Name jsa.mu.Unlock()