Struct Message 

pub struct Message {
    pub id: Vec<u8>,
    pub timestamp: u64,
    pub attempts: u16,
    pub body: Vec<u8>,
    /* private fields */
}

NSQ消息格式

Fields

id: Vec<u8>

唯一消息ID

timestamp: u64

消息时间戳

attempts: u16

消息尝试次数

body: Vec<u8>

消息体

Implementations

impl Message

pub fn new(id: Vec<u8>, body: Vec<u8>, timestamp: u64, attempts: u16) -> Self

创建新消息（用于测试）

pub fn with_responder(self, connection: Arc<Connection>) -> Self

设置消息响应器

pub fn disable_auto_response(&mut self)

禁用自动响应

调用此方法后，消息不会自动发送 FIN/REQ，需要手动调用 finish() 或 requeue()

pub fn is_auto_response_disabled(&self) -> bool

检查是否禁用了自动响应

pub fn has_responded(&self) -> bool

检查消息是否已经响应

pub async fn finish(&self) -> Result<()>

手动发送 FIN 命令

pub async fn requeue(&self, delay: u32) -> Result<()>

手动发送 REQ 命令

pub async fn touch(&self) -> Result<()>

手动发送 TOUCH 命令

pub fn from_bytes(bytes: &[u8]) -> Result<Self>

从字节流解析消息

pub fn id_string(&self) -> String

获取消息ID的字符串表示

Trait Implementations

impl Clone for Message

fn clone(&self) -> Message

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Message

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

Formats the value using the given formatter.