in v2/marshaller.go [70:76]
func (p *DefaultProtoMarshaller) Unmarshal(msg *azservicebus.Message, mb MessageBody) error {
castedMb, ok := mb.(proto.Message)
if !ok {
return fmt.Errorf("message body must be a protobuf message")
}
return proto.Unmarshal(msg.Body, castedMb)
}