Struct ConsumerConfig 

pub struct ConsumerConfig {
    pub queue: QueueName,
    pub consumer_tag: Option<String>,
    pub auto_ack: bool,
    pub prefetch_count: u16,
    pub exclusive: bool,
}

消费者配置

Fields

queue: QueueName

队列名称

consumer_tag: Option<String>

消费者标签

auto_ack: bool

是否自动确认

prefetch_count: u16

预取数量

exclusive: bool

是否独占

Implementations

impl ConsumerConfig

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

创建新的消费者配置

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

设置自动确认

pub fn prefetch(self, count: u16) -> Self

设置预取数量

Trait Implementations

impl Clone for ConsumerConfig

fn clone(&self) -> ConsumerConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConsumerConfig

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

Formats the value using the given formatter.