Struct RedbMessageStore 

pub struct RedbMessageStore { /* private fields */ }

Implementations

impl RedbMessageStore

pub fn open(path: impl AsRef<Path>) -> Result<Self, StoreError>

Open or create a store at the given path.

Trait Implementations

impl MessageStore for RedbMessageStore

fn persist(&self, envelope: &EventEnvelope) -> Result<(), StoreError>

Persist a message. Called before any dispatch.

fn register_consumer( &self, consumer_name: &str, subject: &[u8], queue_groups: &[String], ) -> Result<(), StoreError>

Register a durable consumer for a subject (bincode-encoded bytes).

fn fetch_pending( &self, consumer_name: &str, limit: u32, ) -> Result<Vec<StoredMessage>, StoreError>

Fetch messages not yet delivered to this consumer, up to limit.

fn mark_delivered( &self, message_id: &str, consumer_name: &str, ack_deadline_ms: u64, ) -> Result<(), StoreError>

Mark a message as delivered to a consumer with an ack deadline.

fn ack(&self, message_id: &str, consumer_name: &str) -> Result<(), StoreError>

Acknowledge a message. It won’t be redelivered.

fn nack( &self, message_id: &str, consumer_name: &str, requeue: bool, ) -> Result<(), StoreError>

Negative acknowledge. If requeue is true, reset to pending for immediate redelivery. If false, move to dead-letter.

fn fetch_expired( &self, consumer_name: &str, now_ms: u64, limit: u32, ) -> Result<Vec<StoredMessage>, StoreError>

Fetch messages delivered but not acked before now_ms.

fn gc_acked(&self, older_than_ms: u64) -> Result<u64, StoreError>

Delete acked messages older than older_than_ms. Returns the number of messages removed.

fn list_consumers(&self) -> Result<Vec<String>, StoreError>

List all registered consumer names.