From 95e06a0f570d6cbe0ceaf5ce2802b8a8bac2eb36 Mon Sep 17 00:00:00 2001 From: yukun Date: Mon, 20 Dec 2021 15:41:01 +0800 Subject: [PATCH] [skip e2e]Add comment for rmq reader (#13638) Signed-off-by: fishpenguin --- 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 0325494ab6..11a478fc2b 100644 --- a/internal/util/mqclient/rmq_reader.go +++ b/internal/util/mqclient/rmq_reader.go @@ -37,6 +37,7 @@ func (rr *rmqReader) Seek(id MessageID) error { return rr.r.Seek(msgID) } +// Close closes the rocksmq reader func (rr *rmqReader) Close() { rr.r.Close() }