Struct MemoryDlqHandler 

pub struct MemoryDlqHandler { /* private fields */ }

In-memory DLQ handler for development and testing

Stores dead-lettered events in a Vec with configurable max capacity.

Implementations

impl MemoryDlqHandler

pub fn new(max_events: usize) -> Self

Create a new in-memory DLQ handler

Trait Implementations

impl Default for MemoryDlqHandler

fn default() -> Self

Returns the “default value” for a type.

impl DlqHandler for MemoryDlqHandler

fn handle<'life0, 'async_trait>( &'life0 self, event: DeadLetterEvent, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Handle a dead-lettered event

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

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

Get the number of events currently in the DLQ

fn list<'life0, 'async_trait>( &'life0 self, limit: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<DeadLetterEvent>>> + Send + 'async_trait>>

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

List recent dead-lettered events