Check for store errors

Signed-off-by: Derek Collison <derek@nats.io>
This commit is contained in:
Derek Collison
2020-01-11 09:41:53 -08:00
parent f1a81454b5
commit f211546b3e
2 changed files with 17 additions and 8 deletions

View File

@@ -538,17 +538,24 @@ func (mset *MsgSet) stop(delete bool) error {
}
if delete {
mset.store.Delete()
if err := mset.store.Delete(); err != nil {
return err
}
for _, o := range obs {
o.Delete()
if err := o.Delete(); err != nil {
return err
}
}
} else {
mset.store.Stop()
if err := mset.store.Stop(); err != nil {
return err
}
for _, o := range obs {
o.Stop()
if err := o.Stop(); err != nil {
return err
}
}
}
return nil
}