Trait rocketmq_common::common::message::MessageTrait

source ·

pub trait MessageTrait {
    // Required methods
    fn topic(&self) -> &str;
    fn with_topic(&mut self, topic: impl Into<String>);
    fn tags(&self) -> Option<&str>;
    fn with_tags(&mut self, tags: impl Into<String>);
    fn put_property(&mut self, key: impl Into<String>, value: impl Into<String>);
    fn properties(&self) -> &HashMap<String, String>;
    fn put_user_property(
        &mut self,
        name: impl Into<String>,
        value: impl Into<String>
    );
    fn delay_time_level(&self) -> i32;
    fn with_delay_time_level(&self, level: i32) -> i32;
}