return nil, serialization.NewUnknownEncodingTypeError(row.MessageEncoding)
}
message := persistence.QueueV2Message{
MetaData: persistence.MessageMetadata{ID: row.MessageID},
Data: &commonpb.DataBlob{
EncodingType: encodingType,
Data: row.MessagePayload,
},
}
messages = append(messages, message)
}
nextPageToken := persistence.GetNextPageTokenForReadMessages(messages)