[skip ci]Add comments for rmq client subscribe (#9422)

Signed-off-by: N yukun <kun.yu@zilliz.com>

[skip ci]Add comments for rmq client subscribe (#9422)
Signed-off-by: N yukun <kun.yu@zilliz.com>
f89f2ded · yukun · GitHub · 3dcfff3a · f89f2ded
隐藏空白更改
内联并排

Showing with 1 addition and 0 deletion

internal/util/mqclient/rmq_client.go internal/util/mqclient/rmq_client.go +1 -0

未找到文件。
--- a/internal/util/mqclient/rmq_client.go
+++ b/internal/util/mqclient/rmq_client.go
@@ -44,6 +44,7 @@ func (rc *rmqClient) CreateProducer(options ProducerOptions) (Producer, error) {
 	return &rp, nil
 }

+// Subscribe subscribes a consumer in rmq client
 func (rc *rmqClient) Subscribe(options ConsumerOptions) (Consumer, error) {
 	receiveChannel := make(chan rocksmq.ConsumerMessage, options.BufSize)