mirror of
https://github.com/gogrlx/nats-server.git
synced 2026-04-02 03:38:42 -07:00
@@ -585,7 +585,7 @@ func (s *Server) sendStatsz(subj string) {
|
||||
if s.sys != nil {
|
||||
m.Stats.ActiveServers += len(s.sys.servers)
|
||||
}
|
||||
// JetStream
|
||||
// JetStream
|
||||
if js := s.js; js != nil {
|
||||
jStat := &JetStreamVarz{}
|
||||
s.mu.Unlock()
|
||||
@@ -609,6 +609,7 @@ func (s *Server) sendStatsz(subj string) {
|
||||
m.Stats.JetStream = jStat
|
||||
s.mu.Lock()
|
||||
}
|
||||
// Send message.
|
||||
s.sendInternalMsg(subj, _EMPTY_, &m.Server, &m)
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user