Struct pulsar::consumer::ConsumerBuilder

pub struct ConsumerBuilder<Exe: Executor> { /* fields omitted */ }

Implementations

impl<Exe: Executor> ConsumerBuilder<Exe>

pub fn new(pulsar: &Pulsar<Exe>) -> Self

pub fn with_topic<S: Into<String>>(self, topic: S) -> ConsumerBuilder<Exe>

pub fn with_topics<S: AsRef<str>, I: IntoIterator<Item = S>>(
    self,
    topics: I
) -> ConsumerBuilder<Exe>

pub fn with_topic_regex(self, regex: Regex) -> ConsumerBuilder<Exe>

pub fn with_subscription<S: Into<String>>(self, subscription: S) -> Self

pub fn with_subscription_type(self, subscription_type: SubType) -> Self

pub fn with_lookup_namespace<S: Into<String>>(self, namespace: S) -> Self

Tenant/Namespace to be used when matching against a regex. For other consumers, specify namespace using the <persistent|non-persistent://<tenant>/<namespace>/<topic> topic format. Defaults to public/default if not specifid

pub fn with_topic_refresh(self, refresh_interval: Duration) -> Self

Interval for refreshing the topics when using a topic regex. Unused otherwise.

pub fn with_consumer_id(self, consumer_id: u64) -> Self

pub fn with_consumer_name<S: Into<String>>(self, consumer_name: S) -> Self

pub fn with_batch_size(self, batch_size: u32) -> Self

pub fn with_options(self, options: ConsumerOptions) -> Self

pub fn with_dead_letter_policy(
    self,
    dead_letter_policy: DeadLetterPolicy
) -> Self

pub fn with_unacked_message_resend_delay(self, delay: Option<Duration>) -> Self

The time after which a message is dropped without being acknowledged or nacked that the message is resent. If None, messages will only be resent when a consumer disconnects with pending unacknowledged messages.

pub async fn build<T: DeserializeMessage>(
    self
) -> Result<Consumer<T, Exe>, Error>

Trait Implementations

impl<Exe: Clone + Executor> Clone for ConsumerBuilder<Exe>

fn clone(&self) -> ConsumerBuilder<Exe>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.