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
}