Fix based on feedback from Ivan

Signed-off-by: Derek Collison <derek@nats.io>
This commit is contained in:
Derek Collison
2021-01-20 11:18:10 -08:00
parent fed4c0cce0
commit 55d750733b

View File

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