func()

in v2/marshaller.go [53:67]


func (p *DefaultProtoMarshaller) Marshal(mb MessageBody) (*azservicebus.Message, error) {
	protoContentType := p.ContentType()
	message, ok := mb.(proto.Message)

	if !ok {
		return nil, fmt.Errorf("message must be a protobuf message")
	}
	data, err := proto.Marshal(message)
	if err != nil {
		return nil, err
	}
	msg := &azservicebus.Message{Body: data, ContentType: &protoContentType}

	return msg, nil
}