Only send advisory on create if paused, only send advisory on update …

…from leader

Signed-off-by: Neil Twigg <[email protected]>

server/consumer.go

@@ -1010,7 +1010,9 @@ func (mset *stream) addConsumerWithAssignment(config *ConsumerConfig, oname stri
 
 	// Check/update the pause state
 	o.updatePauseState(&o.cfg)
-	o.sendPauseAdvisoryLocked(&o.cfg)
+	if time.Now().Before(o.cfg.PauseUntil) {
+		o.sendPauseAdvisoryLocked(&o.cfg)
+	}
 
 	if o.isPushMode() {
 		// Check if we are running only 1 replica and that the delivery subject has interest.
@@ -1930,7 +1932,9 @@ func (o *consumer) updateConfig(cfg *ConsumerConfig) error {
 	}
 	if !cfg.PauseUntil.Equal(o.cfg.PauseUntil) {
 		o.updatePauseState(cfg)
-		o.sendPauseAdvisoryLocked(cfg)
+		if o.isLeader() {
+			o.sendPauseAdvisoryLocked(cfg)
+		}
 	}
 
 	// Check for Subject Filters update.