Struct MessageProducer 

pub struct MessageProducer { /* private fields */ }

消息生产者 (提供泛型封装)

Implementations

impl MessageProducer

pub fn new(backend: Box<dyn ProducerBackend>) -> Self

从后端创建生产者

pub async fn send<T: Serialize + Send + Sync>( &self, queue: &str, message: &Message<T>, ) -> QueueResult<MessageId>

发送消息到指定队列

pub async fn send_default<T: Serialize + Send + Sync>( &self, message: &Message<T>, ) -> QueueResult<MessageId>

发送消息到默认队列

pub async fn send_delayed<T: Serialize + Send + Sync>( &self, queue: &str, message: &Message<T>, delay: Duration, ) -> QueueResult<MessageId>

发送延迟消息

pub async fn send_batch<T: Serialize + Send + Sync>( &self, queue: &str, messages: &[Message<T>], ) -> QueueResult<Vec<MessageId>>

批量发送消息

pub fn config(&self) -> &ProducerConfig

获取配置