Struct RecipientTransportStore 

pub struct RecipientTransportStore { /* private fields */ }

Implementations

impl RecipientTransportStore

pub fn new(pool: Arc<ConnectionPool>) -> Self

pub async fn list_due_acknowledgements( &self, now: i64, limit: usize, ) -> StorageResult<Vec<AckJournalEntry>>

Pending entries at or before now (UTC microseconds), oldest first. Pages are bounded to 1,000 entries; a zero limit returns no entries.

pub async fn finish_acknowledgement( &self, delivery_attempt_id: Uuid, ) -> StorageResult<bool>

Finish a pending entry; terminal or absent entries return false unchanged.

pub async fn record_acknowledgement_failed_try( &self, delivery_attempt_id: Uuid, not_before: i64, ) -> StorageResult<bool>

Persist one failed try and its next eligible UTC-microsecond deadline. The integer constraint aborts a counter overflow without changing the row.

pub async fn retire_acknowledgement( &self, delivery_attempt_id: Uuid, reason: AcknowledgementRetirementReason, ) -> StorageResult<bool>

Retire a pending acknowledgement without touching its message or replay claim.

pub async fn ack_if_replayed( &self, binding: Value, recipient_actor: &str, ) -> StorageResult<Option<RecipientCommitResult>>

Answer an already committed logical message before its plaintext is interpreted again. The authenticated caller supplies the current local actor and binding; a hit writes only the new attempt’s ack journal row. A miss makes no claim: commit rechecks replay under its own writer transaction after the new delivery has been validated.

pub async fn commit( &self, input: RecipientCommit, ) -> StorageResult<RecipientCommitResult>

Commit all recipient effects together, or none. A replay keeps its first disposition and creates only the acknowledgement for a new attempt.

A stored disposition writes the message note. A quarantined one writes the quarantine record and no message note (ADR-105 A.8 Receiving, step 4), after dropping the oldest item of its quarantine bound when that bound is full. Dropped items are returned in evicted and logged; their replay identities stay claimed.