Struct ProtobufDataFormat 

pub struct ProtobufDataFormat { /* private fields */ }

Implementations

impl ProtobufDataFormat

pub fn new<P: AsRef<Path>>( proto_path: P, message_name: &str, ) -> Result<Self, CamelError>

pub fn new_with_cache<P: AsRef<Path>>( proto_path: P, message_name: &str, cache: &ProtoCache, ) -> Result<Self, CamelError>

pub fn descriptor(&self) -> &MessageDescriptor

pub fn json_to_dynamic( &self, json_val: Value, ) -> Result<DynamicMessage, CamelError>

pub fn dynamic_to_json(&self, msg: DynamicMessage) -> Result<Value, CamelError>

Trait Implementations

impl DataFormat for ProtobufDataFormat

fn name(&self) -> &str

fn marshal(&self, body: Body) -> Result<Body, CamelError>

fn unmarshal(&self, body: Body) -> Result<Body, CamelError>

fn marshal_in_exchange( &self, exchange: &mut Exchange, body: Body, ) -> Result<Body, CamelError>

Exchange-aware marshal hook. Default delegates to marshal. Override when the format needs Exchange context (e.g., writing metadata headers like CamelCsvHeaderRecord).

fn unmarshal_in_exchange( &self, exchange: &mut Exchange, body: Body, ) -> Result<Body, CamelError>

Exchange-aware unmarshal hook. Default delegates to unmarshal. Override when the format needs Exchange context (e.g., capturing metadata headers like CamelCsvHeaderRecord).