From 3dcfff3a70fb28e77cb12162c0508d0d76bcddff Mon Sep 17 00:00:00 2001 From: yukun Date: Thu, 7 Oct 2021 21:18:52 +0800 Subject: [PATCH] [skip ci]Add comments for rmq client method (#9423) Signed-off-by: yukun --- internal/util/mqclient/rmq_client.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/util/mqclient/rmq_client.go b/internal/util/mqclient/rmq_client.go index 426cc26392..850f0cd9c7 100644 --- a/internal/util/mqclient/rmq_client.go +++ b/internal/util/mqclient/rmq_client.go @@ -62,6 +62,7 @@ func (rc *rmqClient) Subscribe(options ConsumerOptions) (Consumer, error) { return rConsumer, nil } +// EarliestMessageID returns the earliest message ID for rmq client func (rc *rmqClient) EarliestMessageID() MessageID { rID := rocksmq.EarliestMessageID() return &rmqID{messageID: rID}