Struct QueueRuntimeConfig 

pub struct QueueRuntimeConfig {
    pub topic: String,
    pub poll_interval_ms: u64,
    pub max_retries: u32,
}

队列运行时配置

Fields

topic: String

消费主题

poll_interval_ms: u64

队列为空时的轮询间隔（毫秒）

max_retries: u32

单条消息处理最大重试次数（0 表示不重试）

Implementations

impl QueueRuntimeConfig

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

创建新配置

pub fn with_poll_interval(self, ms: u64) -> Self

自定义轮询间隔

pub fn with_max_retries(self, n: u32) -> Self

自定义最大重试次数

Trait Implementations

impl Clone for QueueRuntimeConfig

fn clone(&self) -> QueueRuntimeConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for QueueRuntimeConfig

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

Formats the value using the given formatter.

impl Default for QueueRuntimeConfig

fn default() -> Self

Returns the “default value” for a type.