rocketmq_remoting::protocol::header::message_operation_header

Trait TopicRequestHeaderTrait

Source 
pub trait TopicRequestHeaderTrait: Sync + Send {

Show 14 methods    // Required methods
    fn set_lo(&mut self, lo: Option<bool>);
    fn lo(&self) -> Option<bool>;
    fn set_topic(&mut self, topic: CheetahString);
    fn topic(&self) -> &CheetahString;
    fn broker_name(&self) -> Option<&CheetahString>;
    fn set_broker_name(&mut self, broker_name: CheetahString);
    fn namespace(&self) -> Option<&str>;
    fn set_namespace(&mut self, namespace: CheetahString);
    fn namespaced(&self) -> Option<bool>;
    fn set_namespaced(&mut self, namespaced: bool);
    fn oneway(&self) -> Option<bool>;
    fn set_oneway(&mut self, oneway: bool);
    fn queue_id(&self) -> i32;
    fn set_queue_id(&mut self, queue_id: i32);

}

Required Methods§

Source

fn set_lo(&mut self, lo: Option<bool>)

Source

fn lo(&self) -> Option<bool>

Source

fn set_topic(&mut self, topic: CheetahString)

Source

fn topic(&self) -> &CheetahString

Source

fn broker_name(&self) -> Option<&CheetahString>

Source

fn set_broker_name(&mut self, broker_name: CheetahString)

Source

fn namespace(&self) -> Option<&str>

Source

fn set_namespace(&mut self, namespace: CheetahString)

Source

fn namespaced(&self) -> Option<bool>

Source

fn set_namespaced(&mut self, namespaced: bool)

Source

fn oneway(&self) -> Option<bool>

Source

fn set_oneway(&mut self, oneway: bool)

Source

fn queue_id(&self) -> i32

Source

fn set_queue_id(&mut self, queue_id: i32)

Implementors§