From 426f73ce07eab6a41564cefa30730b0914a6b974 Mon Sep 17 00:00:00 2001
From: yukun <kun.yu@zilliz.com>
Date: Wed, 8 Dec 2021 20:45:35 +0800
Subject: [PATCH] [skip ci]Add comment for rocksmq reader (#13014)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
---
internal/util/mqclient/rmq_reader.go | 1 +
1 file changed, 1 insertion(+)
diff --git a/internal/util/mqclient/rmq_reader.go b/internal/util/mqclient/rmq_reader.go
index db6d791626..89971cdc7b 100644
--- a/internal/util/mqclient/rmq_reader.go
+++ b/internal/util/mqclient/rmq_reader.go
@@ -17,6 +17,7 @@ func (rr *rmqReader) Topic() string {
return rr.r.Topic()
}
+// Next returns the next message of reader, blocking until a message is available
func (rr *rmqReader) Next(ctx context.Context) (Message, error) {
rMsg, err := rr.r.Next(ctx)
if err != nil {