diff --git a/internal/util/mqclient/rmq_client.go b/internal/util/mqclient/rmq_client.go index 02af5c00ca..5781c51d81 100644 --- a/internal/util/mqclient/rmq_client.go +++ b/internal/util/mqclient/rmq_client.go @@ -70,6 +70,7 @@ func (rc *rmqClient) EarliestMessageID() MessageID { return &rmqID{messageID: rID} } +// StringToMsgID converts string id to MessageID func (rc *rmqClient) StringToMsgID(id string) (MessageID, error) { rID, err := strconv.ParseInt(id, 10, 64) if err != nil {