Struct PullConsumerBuilder 

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

Builder for creating pull consumers.

Implementations

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

pub fn durable(self) -> Self

Make this a durable consumer.

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

Set the durable name (different from consumer name).

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

Set a filter subject.

pub fn filter_subjects(self, subjects: Vec<String>) -> Self

Set multiple filter subjects.

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

Set the description.

pub fn ack_policy(self, policy: AckPolicy) -> Self

Set the ack policy.

pub fn ack_wait(self, duration: Duration) -> Self

Set the ack wait duration.

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

Set the maximum number of deliveries.

pub fn replay_policy(self, policy: ReplayPolicy) -> Self

Set the replay policy.

pub fn deliver_policy(self, policy: DeliverPolicy) -> Self

Set the deliver policy.

pub fn start_sequence(self, seq: u64) -> Self

Start at a specific sequence.

pub fn start_time(self, time: OffsetDateTime) -> Self

Start at a specific time.

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

Set the maximum ack pending.

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

Set the maximum waiting.

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

Set the maximum batch size.

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

Set the maximum bytes.

pub fn max_expires(self, duration: Duration) -> Self

Set the maximum expiry.

pub fn inactive_threshold(self, duration: Duration) -> Self

Set the inactive threshold.

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

Set headers only.

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

Set the number of replicas.

pub fn memory_storage(self, memory: bool) -> Self

Set memory storage.

pub fn backoff(self, backoff: Vec<Duration>) -> Self

Set the backoff durations for redelivery.

pub fn metadata(self, metadata: HashMap<String, String>) -> Self

Set metadata.

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

Create the consumer.

pub async fn create_or_update(self) -> Result<PullConsumer<T, C>>

Create or update the consumer.