From fd436207bd813fdf8cfaf9cd84c6d7a195bf181f Mon Sep 17 00:00:00 2001 From: yukun Date: Fri, 17 Dec 2021 22:38:47 +0800 Subject: [PATCH] [skip e2e]Add comment for rmq message (#13633) 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 2ebdaa9be6..d4bdafd4af 100644 --- a/internal/util/mqclient/rmq_message.go +++ b/internal/util/mqclient/rmq_message.go @@ -23,6 +23,7 @@ type rmqMessage struct { msg rocksmq.Message } +// Topic returns the topic name of rocksmq message func (rm *rmqMessage) Topic() string { return rm.msg.Topic }