Trait ReliablePublisher 

pub trait ReliablePublisher: Send + Sync {
    // Required methods
    fn publish_reliable<'life0, 'async_trait>(
        &'life0 self,
        message: ReliableMessage,
    ) -> Pin<Box<dyn Future<Output = Result<DeliveryConfirmation>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn supports_idempotency(&self) -> bool;
    fn reliability_capabilities(&self) -> PublisherCapabilities;
}

Message publisher interface for reliable delivery

Required Methods

fn publish_reliable<'life0, 'async_trait>( &'life0 self, message: ReliableMessage, ) -> Pin<Box<dyn Future<Output = Result<DeliveryConfirmation>> + Send + 'async_trait>>

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

Publish message with reliability guarantees

fn supports_idempotency(&self) -> bool

Check if publisher supports idempotency

fn reliability_capabilities(&self) -> PublisherCapabilities

Get publisher reliability capabilities

Implementors