Race detection fix

Signed-off-by: Derek Collison <derek@nats.io>

server/consumer.go

@@ -695,7 +695,9 @@ func (o *Consumer) readStoredState() error {
 
 	// Setup tracking timer if we have restored pending.
 	if len(o.pending) > 0 && o.ptmr == nil {
+		o.mu.Lock()
 		o.ptmr = time.AfterFunc(o.config.AckWait, o.checkPending)
+		o.mu.Unlock()
 	}
 	return err
 }

server/jetstream.go

@@ -546,7 +546,6 @@ func (a *Account) EnableJetStream(limits *JetStreamAccountLimits) error {
 			if !cfg.Created.IsZero() {
 				obs.setCreated(cfg.Created)
 			}
-
 			if err := obs.readStoredState(); err != nil {
 				s.Warnf("    Error restoring Consumer state: %v", err)
 			}