Struct InterestQueueBuilder 

pub struct InterestQueueBuilder<T, C: CodecType> { /* private fields */ }

Builder for interest-based queues.

Implementations

impl<T, C: CodecType> InterestQueueBuilder<T, C>

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

Set the subject for the queue.

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

Set the maximum number of messages.

pub fn max_bytes(self, max: i64) -> Self

Set the maximum bytes.

pub fn max_age(self, age: Duration) -> Self

Set the maximum age for messages.

pub fn replicas(self, replicas: usize) -> Self

Set the number of replicas.

pub async fn create(self) -> Result<InterestQueue<T, C>>

Create the interest queue.