From 425c7e09d47c3e4f5bc174c68bc488c7576db5df Mon Sep 17 00:00:00 2001
From: yukun <kun.yu@zilliz.com>
Date: Fri, 5 Nov 2021 21:53:22 +0800
Subject: [PATCH] [skip ci]Add rmq retention comment (#11344)

Signed-off-by: fishpenguin <kun.yu@zilliz.com>
---
 internal/util/rocksmq/server/rocksmq/rocksmq_retention.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/internal/util/rocksmq/server/rocksmq/rocksmq_retention.go b/internal/util/rocksmq/server/rocksmq/rocksmq_retention.go
index 66fbea80be..68087db45b 100644
--- a/internal/util/rocksmq/server/rocksmq/rocksmq_retention.go
+++ b/internal/util/rocksmq/server/rocksmq/rocksmq_retention.go
@@ -146,6 +146,7 @@ func (ri *retentionInfo) retention() error {
 	}
 }
 
+// Stop close channel and stop retention
 func (ri *retentionInfo) Stop() {
 	ri.closeOnce.Do(func() {
 		close(ri.closeCh)