diff --git a/internal/pubsub/pubsub.go b/internal/pubsub/pubsub.go index 5f6a1ee3b..707f9cb13 100644 --- a/internal/pubsub/pubsub.go +++ b/internal/pubsub/pubsub.go @@ -281,6 +281,9 @@ func (s *Server) UnsubscribeAll(ctx context.Context, clientID string) error { s.subs.Lock() defer s.subs.Unlock() + if s.subs.index == nil { + return ErrServerStopped + } evict := s.subs.index.findClientID(clientID) if len(evict) == 0 { return ErrSubscriptionNotFound