Struct DMSCMemoryQueue 

pub struct DMSCMemoryQueue { /* private fields */ }

In-memory queue implementation.

This struct implements the DMSCQueue trait for an in-memory queue backend. It supports optional disk persistence for message durability.

Implementations

impl DMSCMemoryQueue

pub fn new(name: &str) -> Self

Creates a new in-memory queue without persistence.

Parameters

• name: The name of the queue

Returns

A new DMSCMemoryQueue instance

pub fn with_persistence(name: &str, persistence_path: &str) -> Self

Creates a new in-memory queue with disk persistence.

Parameters

• name: The name of the queue
• persistence_path: Path to the file where messages will be persisted

Returns

A new DMSCMemoryQueue instance with persistence enabled

Trait Implementations

impl DMSCQueue for DMSCMemoryQueue

fn create_producer<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = DMSCResult<Box<dyn DMSCQueueProducer>>> + Send + 'async_trait>>

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

Creates a new producer for this queue.

Returns

A DMSCResult<Box<dyn DMSCQueueProducer>> containing the producer

fn create_consumer<'life0, 'life1, 'async_trait>( &'life0 self, consumer_group: &'life1 str, ) -> Pin<Box<dyn Future<Output = DMSCResult<Box<dyn DMSCQueueConsumer>>> + Send + 'async_trait>>

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

Creates a new consumer for this queue with the given consumer group.

Parameters

• consumer_group: The name of the consumer group

Returns

A DMSCResult<Box<dyn DMSCQueueConsumer>> containing the consumer

fn get_stats<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = DMSCResult<DMSCQueueStats>> + Send + 'async_trait>>

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

Gets statistics for this queue.

Returns

A DMSCResult<DMSCQueueStats> containing the queue statistics

fn purge<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = DMSCResult<()>> + Send + 'async_trait>>

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

Purges all messages from this queue.

Returns

A DMSCResult<()> indicating success or failure

fn delete<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = DMSCResult<()>> + Send + 'async_trait>>

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

Deletes this queue.

Returns

A DMSCResult<()> indicating success or failure