diff --git a/server/jetstream_cluster.go b/server/jetstream_cluster.go index f0154218cad..b38ec6d2b6c 100644 --- a/server/jetstream_cluster.go +++ b/server/jetstream_cluster.go @@ -1355,6 +1355,8 @@ func (js *jetStream) monitorCluster() { for { select { case <-s.quitCh: + // Server shutting down, but we might receive this before qch, so try to snapshot. + doSnapshot() return case <-rqch: return