Struct MessageExt

pub struct MessageExt {

    pub message: Message,
    pub broker_name: CheetahString,
    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: CheetahString,
    pub commit_log_offset: i64,
    pub body_crc: u32,
    pub reconsume_times: i32,
    pub prepared_transaction_offset: i64,
}

Fields

message: Message

broker_name: CheetahString

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: CheetahString

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) -> &CheetahString

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) -> &CheetahString

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: CheetahString)

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: CheetahString)

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<CheetahString, CheetahString>

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

Trait Implementations

impl Clone for MessageExt

fn clone(&self) -> MessageExt

Returns a duplicate 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.

impl Display for MessageExt

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

Formats the value using the given formatter.

impl MessageTrait for MessageExt

fn put_property(&mut self, key: CheetahString, value: CheetahString)

Adds a property to the message.

fn clear_property(&mut self, name: &str)

Clears a specific property from the message.

fn get_property(&self, name: &CheetahString) -> Option<CheetahString>

Retrieves a property from the message.

fn get_topic(&self) -> &CheetahString

Retrieves the topic of the message.

fn set_topic(&mut self, topic: CheetahString)

Sets the topic for the message.

fn get_flag(&self) -> i32

Retrieves the flag associated with the message.

fn set_flag(&mut self, flag: i32)

Sets the flag for the message.

fn get_body(&self) -> Option<&Bytes>

Retrieves the body of the message.

fn set_body(&mut self, body: Bytes)

Sets the body of the message.

fn get_properties(&self) -> &HashMap<CheetahString, CheetahString>

Retrieves all properties associated with the message.

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

Sets multiple properties for the message.

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

Retrieves the transaction ID associated with the message.

fn set_transaction_id(&mut self, transaction_id: CheetahString)

Sets the transaction ID for the message.

fn get_compressed_body_mut(&mut self) -> &mut Option<Bytes>

fn get_compressed_body(&self) -> Option<&Bytes>

fn set_compressed_body_mut(&mut self, compressed_body: Bytes)

fn as_any(&self) -> &dyn Any

Converts the message into a dynamic Any type.

fn as_any_mut(&mut self) -> &mut dyn Any

Converts the message into a mutable dynamic Any type.

fn set_keys(&mut self, keys: CheetahString)

Sets the keys for the message.

fn put_user_property(&mut self, name: CheetahString, value: CheetahString)

Adds a user-defined property to the message.

fn get_user_property(&self, name: &CheetahString) -> Option<CheetahString>

Retrieves a user-defined property from the message.

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

Retrieves the tags associated with the message.

fn set_tags(&mut self, tags: CheetahString)

Sets the tags for the message.

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

Retrieves the keys associated with the message.

fn set_keys_from_collection(&mut self, key_collection: Vec<String>)

Sets multiple keys from a collection for the message.

fn get_delay_time_level(&self) -> i32

Retrieves the delay time level of the message.

fn set_delay_time_level(&mut self, level: i32)

Sets the delay time level for the message.

fn is_wait_store_msg_ok(&self) -> bool

Checks if the message should wait for store acknowledgment.

fn set_wait_store_msg_ok(&mut self, wait_store_msg_ok: bool)

Sets whether the message should wait for store acknowledgment.

fn set_instance_id(&mut self, instance_id: CheetahString)

Sets the instance ID for the message.

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

Retrieves the buyer ID associated with the message.

fn set_buyer_id(&mut self, buyer_id: CheetahString)

Sets the buyer ID for the message.

fn set_delay_time_sec(&mut self, sec: u64)

Sets the delay time for the message in seconds.

fn get_delay_time_sec(&self) -> u64

Retrieves the delay time for the message in seconds.

fn set_delay_time_ms(&mut self, time_ms: u64)

Sets the delay time for the message in milliseconds.

fn get_delay_time_ms(&self) -> u64

Retrieves the delay time for the message in milliseconds.

fn set_deliver_time_ms(&mut self, time_ms: u64)

Sets the delivery time for the message in milliseconds.

fn get_deliver_time_ms(&self) -> u64

Retrieves the delivery time for the message in milliseconds.