Struct WorkQueueBuilder 

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

Builder for work queues.

Implementations

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

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

Set the subject for the queue.

If not set, defaults to the queue name.

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<WorkQueue<T, C>>

Create the work queue.