Struct MemoryProducerBackend 

pub struct MemoryProducerBackend { /* private fields */ }

内存生产者后端

Implementations

impl MemoryProducerBackend

pub fn new(config: ProducerConfig, manager: Arc<MemoryQueueManager>) -> Self

创建新的内存生产者后端

Trait Implementations

impl ProducerBackend for MemoryProducerBackend

fn send_raw<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, queue: &'life1 str, message: &'life2 RawMessage, ) -> Pin<Box<dyn Future<Output = WaeResult<MessageId>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

发送原始消息到指定队列

fn send_raw_default<'life0, 'life1, 'async_trait>( &'life0 self, message: &'life1 RawMessage, ) -> Pin<Box<dyn Future<Output = WaeResult<MessageId>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

发送原始消息到默认队列

fn send_raw_delayed<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, queue: &'life1 str, message: &'life2 RawMessage, delay: Duration, ) -> Pin<Box<dyn Future<Output = WaeResult<MessageId>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

发送延迟消息

fn send_raw_batch<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, queue: &'life1 str, messages: &'life2 [RawMessage], ) -> Pin<Box<dyn Future<Output = WaeResult<Vec<MessageId>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

批量发送消息

fn config(&self) -> &ProducerConfig

获取生产者配置