diff --git a/internal/util/mqclient/rmq_client.go b/internal/util/mqclient/rmq_client.go
index 312db5a37a..cf9b4d6a5a 100644
--- a/internal/util/mqclient/rmq_client.go
+++ b/internal/util/mqclient/rmq_client.go
@@ -79,6 +79,7 @@ func (rc *rmqClient) StringToMsgID(id string) (MessageID, error) {
 	return &rmqID{messageID: rID}, nil
 }
 
+// BytesToMsgID converts a byte array to messageID
 func (rc *rmqClient) BytesToMsgID(id []byte) (MessageID, error) {
 	rID, err := DeserializeRmqID(id)
 	if err != nil {