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
 }