Struct PublishOptions 

pub struct PublishOptions {
    pub persistent: bool,
    pub prefetch_count: u16,
    pub use_retry_queue: bool,
    pub use_dead_letter: bool,
    pub max_retries: usize,
    pub retry_interval_ms: u64,
    pub processing_timeout_ms: Option<u64>,
}

Options controlling queue declaration and failure handling.

T elsewhere is the JSON message type; these options apply to any message type.

Fields

persistent: bool

Declare queues as durable. Defaults to true.

prefetch_count: u16

Maximum unacknowledged messages per consumer. Defaults to 16.

use_retry_queue: bool

Declare and use the <name>.retry queue. Defaults to false.

use_dead_letter: bool

Declare and use the <name>.dlq queue. Defaults to false.

max_retries: usize

Times a message is resent to the retry queue before dead-lettering. Defaults to 5.

retry_interval_ms: u64

Delay before a retry-queue message is redelivered. Defaults to 30_000 ms.

processing_timeout_ms: Option<u64>

Per-message handler timeout; None means no timeout. Defaults to None.

Trait Implementations

impl Clone for PublishOptions

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PublishOptions

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

Formats the value using the given formatter.

impl Default for PublishOptions

fn default() -> Self

Returns the “default value” for a type.