From 0456188deab4e5b973dfcbb0527023f18cea4b57 Mon Sep 17 00:00:00 2001 From: yukun Date: Fri, 17 Dec 2021 22:12:54 +0800 Subject: [PATCH] [skip e2e]Add comment for rmq message (#13628) 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 21094eb5bb..2ebdaa9be6 100644 --- a/internal/util/mqclient/rmq_message.go +++ b/internal/util/mqclient/rmq_message.go @@ -31,6 +31,7 @@ func (rm *rmqMessage) Properties() map[string]string { return nil } +// Payload returns the payload of rocksmq message func (rm *rmqMessage) Payload() []byte { return rm.msg.Payload }