Struct ReceiveOptions 

pub struct ReceiveOptions {
    pub max_messages: u32,
    pub timeout: Duration,
    pub session_id: Option<SessionId>,
    pub accept_any_session: bool,
    pub lock_duration: Option<Duration>,
    pub peek_only: bool,
    pub from_sequence_number: Option<u64>,
}

Configuration options for receiving messages from queues

Fields

max_messages: u32

Maximum number of messages to receive in a batch

timeout: Duration

Timeout duration for receive operations

session_id: Option<SessionId>

Session ID for session-specific message consumption

accept_any_session: bool

Whether to accept any available session

lock_duration: Option<Duration>

Message lock duration for processing time management

peek_only: bool

Peek-only mode for message inspection without consumption

from_sequence_number: Option<u64>

Sequence number for replay and recovery scenarios

Implementations

impl ReceiveOptions

pub fn new() -> Self

Create new receive options with defaults

pub fn with_max_messages(self, max: u32) -> Self

Set maximum number of messages to receive

pub fn with_timeout(self, timeout: Duration) -> Self

Set timeout duration

pub fn with_session_id(self, session_id: SessionId) -> Self

Set specific session ID to consume from

pub fn accept_any_session(self) -> Self

Accept messages from any available session

pub fn with_lock_duration(self, duration: Duration) -> Self

Set message lock duration

pub fn peek_only(self) -> Self

Enable peek-only mode (inspect without consuming)

pub fn from_sequence_number(self, sequence: u64) -> Self

Set starting sequence number for replay

Trait Implementations

impl Clone for ReceiveOptions

fn clone(&self) -> ReceiveOptions

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ReceiveOptions

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

Formats the value using the given formatter.

impl Default for ReceiveOptions

fn default() -> Self

Returns the “default value” for a type.