Struct rocketmq_common::common::message::message_single::MessageExt

pub struct MessageExt {

    pub message: Message,
    pub broker_name: String,
    pub queue_id: i32,
    pub store_size: i32,
    pub queue_offset: i64,
    pub sys_flag: i32,
    pub born_timestamp: i64,
    pub born_host: SocketAddr,
    pub store_timestamp: i64,
    pub store_host: SocketAddr,
    pub msg_id: String,
    pub commit_log_offset: i64,
    pub body_crc: u32,
    pub reconsume_times: i32,
    pub prepared_transaction_offset: i64,
}

Fields

message: Message

broker_name: String

queue_id: i32

store_size: i32

queue_offset: i64

sys_flag: i32

born_timestamp: i64

born_host: SocketAddr

store_timestamp: i64

store_host: SocketAddr

msg_id: String

commit_log_offset: i64

body_crc: u32

reconsume_times: i32

prepared_transaction_offset: i64

Implementations

impl MessageExt

pub fn socket_address_2_byte_buffer(ip: &SocketAddr) -> Bytes

pub fn born_host_bytes(&self) -> Bytes

pub fn born_store_bytes(&self) -> Bytes

pub fn topic(&self) -> &str

pub fn born_host(&self) -> SocketAddr

pub fn store_host(&self) -> SocketAddr

pub fn with_born_host_v6_flag(&mut self)

pub fn with_store_host_v6_flag(&mut self)

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

pub fn sys_flag(&self) -> i32

pub fn body_crc(&self) -> u32

pub fn queue_id(&self) -> i32

pub fn flag(&self) -> i32

pub fn message_inner(&self) -> &Message

pub fn broker_name(&self) -> &str

pub fn store_size(&self) -> i32

pub fn queue_offset(&self) -> i64

pub fn born_timestamp(&self) -> i64

pub fn store_timestamp(&self) -> i64

pub fn msg_id(&self) -> &str

pub fn commit_log_offset(&self) -> i64

pub fn reconsume_times(&self) -> i32

pub fn prepared_transaction_offset(&self) -> i64

pub fn set_message_inner(&mut self, message_inner: Message)

pub fn set_broker_name(&mut self, broker_name: String)

pub fn set_queue_id(&mut self, queue_id: i32)

pub fn set_store_size(&mut self, store_size: i32)

pub fn set_queue_offset(&mut self, queue_offset: i64)

pub fn set_sys_flag(&mut self, sys_flag: i32)

pub fn set_born_timestamp(&mut self, born_timestamp: i64)

pub fn set_born_host(&mut self, born_host: SocketAddr)

pub fn set_store_timestamp(&mut self, store_timestamp: i64)

pub fn set_store_host(&mut self, store_host: SocketAddr)

pub fn set_msg_id(&mut self, msg_id: String)

pub fn set_commit_log_offset(&mut self, commit_log_offset: i64)

pub fn set_body_crc(&mut self, body_crc: u32)

pub fn set_reconsume_times(&mut self, reconsume_times: i32)

pub fn set_prepared_transaction_offset( &mut self, prepared_transaction_offset: i64 )

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

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

Trait Implementations

impl Clone for MessageExt

fn clone(&self) -> MessageExt

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for MessageExt

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

Formats the value using the given formatter.

impl Default for MessageExt

fn default() -> Self

Returns the “default value” for a type.