Struct rocketmq_common::common::message::message_single::Message

pub struct Message {
    pub topic: String,
    pub flag: i32,
    pub properties: HashMap<String, String>,
    pub body: Option<Bytes>,
    pub transaction_id: Option<String>,
}

Fields

topic: String

flag: i32

properties: HashMap<String, String>

body: Option<Bytes>

transaction_id: Option<String>

Implementations

impl Message

pub fn clear_property(&mut self, name: impl Into<String>)

pub fn set_properties(&mut self, properties: HashMap<String, String>)

pub fn get_property(&self, key: impl Into<String>) -> Option<String>

pub fn body(&self) -> Option<Bytes>

pub fn flag(&self) -> i32

pub fn topic(&self) -> &str

pub fn properties(&self) -> &HashMap<String, String>

pub fn transaction_id(&self) -> Option<&str>

pub fn get_tags(&self) -> Option<String>

pub fn is_wait_store_msg_ok(&self) -> bool

Trait Implementations

impl Clone for Message

fn clone(&self) -> Message

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Message

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for Message

fn default() -> Message

Returns the “default value” for a type.

impl MessageTrait for Message

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