From 872f6f8a0463fd08b932d6c812c9af45c07ba2e9 Mon Sep 17 00:00:00 2001 From: yukun Date: Thu, 4 Nov 2021 20:49:20 +0800 Subject: [PATCH] [skip ci]Add rmq client comments (#11271) Signed-off-by: fishpenguin --- internal/util/mqclient/rmq_client.go | 1 + 1 file changed, 1 insertion(+) 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 {