Struct ConsumerGroup 

pub struct ConsumerGroup {
    pub name: String,
    /* private fields */
}

A consumer group manages message delivery and acknowledgment for a set of consumers reading from the same queue.

Fields

name: String

Group name

Implementations

impl ConsumerGroup

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

Create a new consumer group

pub fn add_consumer(&mut self, name: &str)

Register a consumer (or return existing)

pub fn deliver(&mut self, seq: u64, consumer: &str)

Record that a message was delivered to a consumer

pub fn ack(&mut self, seq: u64) -> bool

Acknowledge a message (remove from pending)

pub fn nack(&mut self, seq: u64) -> bool

Negative acknowledge: re-make the message available

pub fn pending_for_consumer(&self, consumer: &str) -> Vec<&PendingEntry>

Get all pending entries for a consumer

pub fn all_pending(&self) -> Vec<&PendingEntry>

Get all pending entries

pub fn pending_count(&self) -> usize

Number of pending messages

pub fn consumers(&self) -> Vec<&ConsumerState>

List consumers

pub fn is_pending(&self, seq: u64) -> bool

Check if a message is pending