fixing crash when disabling already shut down client

Signed-off-by: Matthias Hanel <mh@synadia.com>
This commit is contained in:
Matthias Hanel
2021-03-08 19:57:18 -05:00
parent 4d1fc3a449
commit bea37b089c

View File

@@ -288,6 +288,10 @@ func (s *Server) DisableJetStream() error {
if s.JetStreamIsClustered() {
isLeader := s.JetStreamIsLeader()
js, cc := s.getJetStreamCluster()
if js == nil {
s.shutdownJetStream()
return nil
}
js.mu.RLock()
meta := cc.meta
js.mu.RUnlock()