mirror of
https://github.com/gogrlx/nats-server.git
synced 2026-04-02 03:38:42 -07:00
@@ -304,8 +304,8 @@ func (s *Server) DisableJetStream() error {
|
||||
|
||||
if meta != nil {
|
||||
if isLeader {
|
||||
js.remapStreams(meta.ID())
|
||||
s.Warnf("JetStream initiating meta leader transfer")
|
||||
meta.StepDown()
|
||||
select {
|
||||
case <-s.quitCh:
|
||||
return nil
|
||||
|
||||
Reference in New Issue
Block a user