[skip ci]Add comments for rocksmq close (#9519)

Signed-off-by: fishpenguin <kun.yu@zilliz.com>
This commit is contained in:
yukun 2021-10-09 00:11:36 +08:00 committed by GitHub
parent 30395cb1b1
commit 969c78e79d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -166,6 +166,10 @@ func NewRocksMQ(name string, idAllocator allocator.GIDAllocator) (*rocksmq, erro
return rmq, nil
}
// Close step:
// 1. Stop retention
// 2. Destroy all consumer groups and topics
// 3. Close rocksdb instance
func (rmq *rocksmq) Close() {
rmq.stopRetention()
rmq.storeMu.Lock()