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

Signed-off-by: fishpenguin <kun.yu@zilliz.com>
This commit is contained in:
yukun 2021-12-08 20:45:35 +08:00 committed by GitHub
parent 490f8b50e1
commit 426f73ce07
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -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 {