350
func (q queueV2) extractQueueMetadata(metadataRow *sqlplugin.QueueV2MetadataRow) (*persistencespb.Queue, error) {
351
if metadataRow.MetadataEncoding != enumspb.ENCODING_TYPE_PROTO3.String() {
353
>
"queue with type %v and name %v has invalid encoding: %w",
354
>
metadataRow.QueueType,
355
>
metadataRow.QueueName,
356
>
serialization.NewUnknownEncodingTypeError(metadataRow.MetadataEncoding, enumspb.ENCODING_TYPE_PROTO3),
357
>
)
358
>
}
359
qm := &persistencespb.Queue{}
360
err := qm.Unmarshal(metadataRow.MetadataPayload)