Struct RawMessage 

pub struct RawMessage {
    pub data: Vec<u8>,
    pub metadata: MessageMetadata,
}

原始消息 (字节形式)

Fields

data: Vec<u8>

消息数据

metadata: MessageMetadata

消息元数据

Implementations

impl RawMessage

pub fn new(data: Vec<u8>) -> 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

添加自定义头

impl RawMessage

pub fn into_typed<T: DeserializeOwned>(self) -> WaeResult<Message<T>>

反序列化为泛型消息

Trait Implementations

impl Clone for RawMessage

fn clone(&self) -> RawMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RawMessage

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

Formats the value using the given formatter.