Struct QueueConfig 

pub struct QueueConfig {
    pub name: QueueName,
    pub durable: bool,
    pub auto_delete: bool,
    pub max_messages: Option<u64>,
    pub max_message_size: Option<u64>,
    pub message_ttl: Option<u64>,
    pub dead_letter_queue: Option<QueueName>,
}

队列配置

Fields

name: QueueName

队列名称

durable: bool

是否持久化

auto_delete: bool

是否自动删除 (当没有消费者时)

max_messages: Option<u64>

最大消息数

max_message_size: Option<u64>

最大消息大小 (字节)

message_ttl: Option<u64>

消息存活时间 (毫秒)

dead_letter_queue: Option<QueueName>

死信队列

Implementations

impl QueueConfig

pub fn new(name: impl Into<String>) -> Self

创建新的队列配置

pub fn durable(self, durable: bool) -> Self

设置持久化

pub fn auto_delete(self, auto_delete: bool) -> Self

设置自动删除

pub fn max_messages(self, max: u64) -> Self

设置最大消息数

pub fn message_ttl(self, ttl_ms: u64) -> Self

设置消息 TTL

pub fn dead_letter_queue(self, queue: impl Into<String>) -> Self

设置死信队列

Trait Implementations

impl Clone for QueueConfig

fn clone(&self) -> QueueConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for QueueConfig

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

Formats the value using the given formatter.