Struct MemoryInboxStore 

pub struct MemoryInboxStore { /* private fields */ }

In-memory idempotency records scoped by consumer name.

Implementations

impl MemoryInboxStore

pub fn new() -> Self

Creates an empty inbox store.

Trait Implementations

impl Debug for MemoryInboxStore

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for MemoryInboxStore

fn default() -> MemoryInboxStore

Returns the “default value” for a type.

impl InboxStore for MemoryInboxStore

fn claim<'a>( &'a self, consumer: &'a str, id: &'a MessageId, claim_id: DeliveryClaimId, received_at: SystemTime, lease_until: SystemTime, ) -> BoxFuture<'a, SoapResult<InboxClaim>>

Atomically claims a message for a named consumer using an exclusive lease.

fn complete<'a>( &'a self, consumer: &'a str, id: &'a MessageId, claim_id: &'a DeliveryClaimId, completed_at: SystemTime, ) -> BoxFuture<'a, SoapResult<()>>

Marks a claimed message as processed if the lease identity still owns it.

fn release<'a>( &'a self, consumer: &'a str, id: &'a MessageId, claim_id: &'a DeliveryClaimId, released_at: SystemTime, ) -> BoxFuture<'a, SoapResult<()>>

Releases a failed claim so adapter policy may permit another attempt.