[skip ci]Add comment for rocksmq reader (#12731)

Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-12-03 20:33:50 +08:00 · 2021-12-03 20:33:50 +08:00 · 5702494efe
parent a1ab961e49
commit 5702494efe
1 changed files with 1 additions and 0 deletions
--- a/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go
+++ b/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go
@ -1067,6 +1067,7 @@ func (rmq *rocksmq) HasNext(topicName string, readerName string, messageIDInclus
 	return reader.HasNext(messageIDInclusive)
 }

+// CloseReader close a reader
 func (rmq *rocksmq) CloseReader(topicName string, readerName string) {
 	if rmq.isClosed() {
 		return