Struct QueueWrapper 

pub struct QueueWrapper { /* private fields */ }

Implementations

impl QueueWrapper

pub fn new(provider: MqProvider) -> Self

pub fn with_reconnect(self, policy: ReconnectPolicy) -> Self

设置重连策略

启用后，publish / consume 在遇到 MqError::Connection 错误时 会按指数退避策略自动重试，最多重试 policy.max_retries 次。

pub async fn publish(&self, topic: &str, message: &[u8]) -> Result<(), MqError>

pub async fn consume(&self, topic: &str) -> Result<Option<Message>, MqError>

pub async fn ack(&self, message_id: &str) -> Result<(), MqError>

pub async fn subscribe(&self, topic: &str) -> Result<(), MqError>

pub async fn nack(&self, message_id: &str) -> Result<(), MqError>

消息重回队列尾部（带重试次数追踪）

委托给底层 queue 的 nack 实现。重连策略不应用于 nack。

pub async fn reject(&self, message_id: &str) -> Result<(), MqError>

消息直接进入死信队列

委托给底层 queue 的 reject 实现。重连策略不应用于 reject。