From a4cffb7f1c79029242655bddf110b5738c22e6c5 Mon Sep 17 00:00:00 2001 From: yukun Date: Thu, 7 Oct 2021 21:10:55 +0800 Subject: [PATCH] [skip ci]Add comments for rmqMessage (#9420) Signed-off-by: yukun --- 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 b39f5d9cb4..eb472a9e98 100644 --- a/internal/util/mqclient/rmq_message.go +++ b/internal/util/mqclient/rmq_message.go @@ -18,6 +18,7 @@ import ( // Check rmqMessage implements ConsumerMessage var _ ConsumerMessage = (*rmqMessage)(nil) +// rmqMessage wraps the message for rocksmq type rmqMessage struct { msg rocksmq.ConsumerMessage }