Struct ReplyMessageRequestHeader

pub struct ReplyMessageRequestHeader {

    pub producer_group: CheetahString,
    pub topic: CheetahString,
    pub default_topic: CheetahString,
    pub default_topic_queue_nums: i32,
    pub queue_id: i32,
    pub sys_flag: i32,
    pub born_timestamp: i64,
    pub flag: i32,
    pub properties: Option<CheetahString>,
    pub reconsume_times: Option<i32>,
    pub unit_mode: Option<bool>,
    pub born_host: CheetahString,
    pub store_host: CheetahString,
    pub store_timestamp: i64,
    pub topic_request: Option<TopicRequestHeader>,
}

Represents the header of a reply message request.

Fields

producer_group: CheetahString

Producer group associated with the message.

topic: CheetahString

The topic of the message.

default_topic: CheetahString

Default topic used when the specified topic is not found.

default_topic_queue_nums: i32

Number of queues in the default topic.

queue_id: i32

Queue ID of the message.

sys_flag: i32

System flags associated with the message.

born_timestamp: i64

Timestamp of when the message was born.

flag: i32

Flags associated with the message.

properties: Option<CheetahString>

Properties of the message (nullable).

reconsume_times: Option<i32>

Number of times the message has been reconsumed (nullable).

unit_mode: Option<bool>

Whether the message processing is in unit mode (nullable).

born_host: CheetahString

Host where the message was born.

store_host: CheetahString

Host where the message is stored.

store_timestamp: i64

Timestamp of when the message was stored.

topic_request: Option<TopicRequestHeader>

Trait Implementations

impl CommandCustomHeader for ReplyMessageRequestHeader

fn to_map(&self) -> Option<HashMap<CheetahString, CheetahString>>

Converts the implementing type to a map.

fn check_fields(&self) -> Result<(), Error>

Checks the fields of the implementing type.

fn write_if_not_null(&self, out: &mut BytesMut, key: &str, value: &str)

Writes the provided key to the out buffer if the value is not empty.

fn encode_fast(&mut self, _out: &mut BytesMut)

A placeholder function for fast encoding.

fn decode_fast( &mut self, _fields: &HashMap<CheetahString, CheetahString>, ) -> RocketMQResult<()>

A placeholder function for fast decoding.

fn support_fast_codec(&self) -> bool

Indicates whether the implementing type supports fast codec.

fn get_and_check_not_none( &self, map: &HashMap<CheetahString, CheetahString>, field: &CheetahString, ) -> RocketMQResult<CheetahString>

Retrieves the value associated with the specified field from the provided map.

impl Debug for ReplyMessageRequestHeader

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

Formats the value using the given formatter.

impl Default for ReplyMessageRequestHeader

fn default() -> ReplyMessageRequestHeader

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for ReplyMessageRequestHeader

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl FromMap for ReplyMessageRequestHeader

type Error = RocketmqError

type Target = ReplyMessageRequestHeader

fn from( map: &HashMap<CheetahString, CheetahString>, ) -> Result<Self::Target, Self::Error>

Converts the implementing type from a map.

impl Serialize for ReplyMessageRequestHeader

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.