Function newQueueRow

common/persistence/sql/queue.go:379–391

(
	queueType persistence.QueueType,
	messageID int64,
	blob *commonpb.DataBlob,
)

}

func newQueueRow(
	queueType persistence.QueueType,
	messageID int64,
	blob *commonpb.DataBlob,
) sqlplugin.QueueMessageRow {

	return sqlplugin.QueueMessageRow{
		QueueType:       queueType,
		MessageID:       messageID,
		MessagePayload:  blob.Data,
		MessageEncoding: blob.EncodingType.String(),
	}
}