Struct OutboxManager 

pub struct OutboxManager<S, P> { /* private fields */ }

Implementations

impl<S, P> OutboxManager<S, P>

where S: OutboxStorage + Send + Sync + 'static, P: Transport + Send + Sync + 'static,

pub fn new( storage: Arc<S>, publisher: Arc<P>, config: Arc<OutboxConfig>, shutdown_rx: Receiver<bool>, ) -> Self

pub async fn run(self) -> Result<(), OutboxError>

Starts the main outbox worker loop.

This method will run until a shutdown signal is received via the shutdown_rx channel. It handles event processing, database notifications, and periodic garbage collection.

Errors

Returns an OutboxError if the worker encounters a terminal failure that it cannot recover from (though currently the loop primarily logs errors and continues).