Struct BusOutboxPublishHook 

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

Publishes committed outbox rows through publisher and settles their claims in store. The store must be the same outbox store the commit wrote to.

Implementations

impl<S, P> BusOutboxPublishHook<S, P>

pub fn new(store: S, publisher: P, max_attempts: u32) -> Self

Build the hook from the outbox store, a message publisher (e.g. a BusPublisher over a *Bus), and the publish-failure ceiling.

Trait Implementations

impl<S, P> OutboxPublishHook for BusOutboxPublishHook<S, P>

where S: AsyncOutboxStore, P: AsyncMessagePublisher,

fn publish_claimed<'a>( &'a self, claimed: OutboxMessage, ) -> Pin<Box<dyn Future<Output = Result<(), RepositoryError>> + Send + 'a>>

Publish a committed, claimed outbox row and settle its claim. Publish failures are absorbed (the row stays retryable for the worker); only a store error surfaces.