diff --git a/internal/util/mqclient/rmq_id.go b/internal/util/mqclient/rmq_id.go index f4f68cb445..816ae11257 100644 --- a/internal/util/mqclient/rmq_id.go +++ b/internal/util/mqclient/rmq_id.go @@ -24,6 +24,7 @@ type rmqID struct { // Check if rmqID implements MessageID interface var _ MessageID = &rmqID{} +// Serialize convert rmq message id to []byte func (rid *rmqID) Serialize() []byte { return SerializeRmqID(rid.messageID) }