Struct Message 

pub struct Message<T> {
    pub payload: T,
    pub metadata: MessageMetadata,
}

消息封装 (泛型)

Fields

payload: T

消息体

metadata: MessageMetadata

消息元数据

Implementations

impl<T> Message<T>

pub fn new(payload: T) -> Self

创建新消息

pub fn with_correlation_id(self, id: impl Into<String>) -> Self

设置关联 ID

pub fn with_reply_to(self, queue: impl Into<String>) -> Self

设置回复队列

pub fn with_priority(self, priority: u8) -> Self

设置优先级

pub fn with_expiration(self, ms: u64) -> Self

设置过期时间

pub fn with_header( self, key: impl Into<String>, value: impl Into<String>, ) -> Self

添加自定义头

pub fn into_raw(self) -> QueueResult<RawMessage>

where T: Serialize,

序列化为原始消息

pub fn to_raw(&self) -> QueueResult<RawMessage>

where T: Serialize,

序列化为原始消息 (引用版本)

Trait Implementations

impl<T: Clone> Clone for Message<T>

fn clone(&self) -> Message<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for Message<T>

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

Formats the value using the given formatter.