From d382d596da08497f901b4e3683f9e8f839dbb88d Mon Sep 17 00:00:00 2001
From: yukun <kun.yu@zilliz.com>
Date: Fri, 17 Dec 2021 19:13:06 +0800
Subject: [PATCH] [skip e2e]Add comment for rmq reader (#13625)

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 89971cdc7b..0325494ab6 100644
--- a/internal/util/mqclient/rmq_reader.go
+++ b/internal/util/mqclient/rmq_reader.go
@@ -27,6 +27,7 @@ func (rr *rmqReader) Next(ctx context.Context) (Message, error) {
 	return msg, nil
 }
 
+// HasNext returns whether reader has next message
 func (rr *rmqReader) HasNext() bool {
 	return rr.r.HasNext()
 }