Struct rocketmq_common::common::message::message_single::MessageExtBrokerInner

pub struct MessageExtBrokerInner {
    pub message_ext_inner: MessageExt,
    pub properties_string: String,
    pub tags_code: i64,
    pub encoded_buff: Option<BytesMut>,
    pub encode_completed: bool,
    pub version: MessageVersion,
}

Fields

message_ext_inner: MessageExt

properties_string: String

tags_code: i64

encoded_buff: Option<BytesMut>

encode_completed: bool

version: MessageVersion

Implementations

impl MessageExtBrokerInner

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

pub fn with_version(&mut self, version: MessageVersion)

pub fn version(&self) -> MessageVersion

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 born_timestamp(&self) -> i64

pub fn store_timestamp(&self) -> i64

pub fn born_host_bytes(&self) -> Bytes

pub fn store_host_bytes(&self) -> Bytes

pub fn reconsume_times(&self) -> i32

pub fn prepared_transaction_offset(&self) -> i64

pub fn property(&self, name: &str) -> Option<String>

pub fn properties_string(&self) -> &str

pub fn queue_offset(&self) -> i64

pub fn tags_string2tags_code(_filter: &TopicFilterType, tags: &str) -> i64

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

pub fn is_wait_store_msg_ok(&self) -> bool

pub fn body_len(&self) -> usize

Trait Implementations

impl Debug for MessageExtBrokerInner

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

Formats the value using the given formatter.

impl Default for MessageExtBrokerInner

fn default() -> MessageExtBrokerInner

Returns the “default value” for a type.