From c55d49f732224e6bb391c6c782c841106a7298e2 Mon Sep 17 00:00:00 2001 From: yukun Date: Fri, 17 Dec 2021 19:28:41 +0800 Subject: [PATCH] [skip e2e]Add comment for rmq message (#13627) Signed-off-by: fishpenguin --- internal/util/mqclient/rmq_message.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/util/mqclient/rmq_message.go b/internal/util/mqclient/rmq_message.go index ddd12ed961..21094eb5bb 100644 --- a/internal/util/mqclient/rmq_message.go +++ b/internal/util/mqclient/rmq_message.go @@ -35,6 +35,7 @@ func (rm *rmqMessage) Payload() []byte { return rm.msg.Payload } +// ID returns the id of rocksmq message func (rm *rmqMessage) ID() MessageID { return &rmqID{messageID: rm.msg.MsgID} }