Struct MessageQueue 

pub struct MessageQueue { /* private fields */ }

Message queue for buffering raw message data

Supports both bounded and unbounded queues with optional message dropping.

Implementations

impl MessageQueue

pub fn new() -> Self

Create a new message queue with default configuration

pub fn with_config(config: QueueConfig) -> Self

Create a new message queue with custom configuration

pub async fn enqueue(&self, data: Vec<u8>) -> Result<()>

Enqueue a message (non-blocking)

Arguments

• data - Raw message bytes

Returns

Ok(()) if enqueued, Err if queue is full and not configured to drop

pub async fn dequeue(&self) -> Result<Vec<u8>>

Dequeue a message (blocking until message available)

Returns

Message bytes or error if queue is closed

pub async fn try_dequeue(&self) -> Result<Vec<u8>>

Try to dequeue a message (non-blocking)

Returns

Some(data) if message available, None if queue is empty

pub async fn size(&self) -> usize

Get current queue size

pub async fn stats(&self) -> QueueStats

Get queue statistics

pub async fn is_empty(&self) -> bool

Check if queue is empty

pub fn config(&self) -> &QueueConfig

Get queue configuration

Trait Implementations

impl Default for MessageQueue

fn default() -> Self

Returns the “default value” for a type.