Struct MessageBatcher 

pub struct MessageBatcher { /* private fields */ }

Message batcher for high-throughput publishing

Implementations

impl MessageBatcher

pub async fn new(publisher: Publisher, config: BatchConfig) -> Result<Self>

Create a new message batcher

pub async fn with_metrics( publisher: Publisher, config: BatchConfig, metrics: RustRabbitMetrics, ) -> Result<Self>

Create a new message batcher with metrics

pub async fn queue_message<T>( &self, queue_name: &str, message: &T, options: Option<PublishOptions>, ) -> Result<()>

where T: Serialize,

Add a message to the batch queue

pub fn queue_len(&self) -> usize

Get current queue length (approximate)

pub fn is_nearly_full(&self) -> bool

Check if the batch queue is nearly full

Trait Implementations

impl Debug for MessageBatcher

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

Formats the value using the given formatter.