Unpause the topic when necessary

nsqio · May 11, 2018 · 90a4f63 · 90a4f63
1 parent 2bf2517
commit 90a4f63
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/nsqd/nsqd.go b/nsqd/nsqd.go
@@ -358,9 +358,6 @@ func (n *NSQD) LoadMetadata() error {
 			continue
 		}
 		topic := n.GetTopic(t.Name)
-		if t.Paused {
-			topic.Pause()
-		}
 
 		for _, c := range t.Channels {
 			if !protocol.IsValidChannelName(c.Name) {
@@ -372,7 +369,9 @@ func (n *NSQD) LoadMetadata() error {
 				channel.Pause()
 			}
 		}
-		topic.UnPause()
+		if !t.Paused {
+			topic.UnPause()
+		}
 	}
 	return nil
 }