Struct ClaimOutboxMessages 

pub struct ClaimOutboxMessages {
    pub worker_id: String,
    pub batch_size: usize,
    pub lease: Duration,
    pub destination: Option<String>,
    pub message_ids: Option<Vec<String>>,
}

Fields

worker_id: String

batch_size: usize

lease: Duration

destination: Option<String>

message_ids: Option<Vec<String>>

Restrict the claim to this explicit set of message ids. None claims the next claimable batch in created-at order (normal worker polling); Some claims only the listed ids (after-commit immediate dispatch). Ids that are not currently claimable are simply skipped — a raced id is not an error.

Implementations

impl ClaimOutboxMessages

pub fn new( worker_id: impl Into<String>, batch_size: usize, lease: Duration, ) -> Self

pub fn to_destination(self, destination: impl Into<String>) -> Self

pub fn for_ids( worker_id: impl Into<String>, ids: Vec<String>, lease: Duration, ) -> Self

Restrict this claim to an explicit list of message ids (after-commit immediate dispatch). The batch size is bounded by the id count.

Trait Implementations

impl Clone for ClaimOutboxMessages

fn clone(&self) -> ClaimOutboxMessages

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ClaimOutboxMessages

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

Formats the value using the given formatter.

impl Eq for ClaimOutboxMessages

impl PartialEq for ClaimOutboxMessages

fn eq(&self, other: &ClaimOutboxMessages) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for ClaimOutboxMessages