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 {