Struct ManagedConsumerBuilder 

pub struct ManagedConsumerBuilder<T: Send + Sync + Clone + 'static> { /* private fields */ }

Builder for ManagedConsumer.

Implementations

impl<T: Send + Sync + Clone + 'static> ManagedConsumerBuilder<T>

pub fn new( name: impl Into<String>, inner: Arc<dyn MessageConsumer<T>>, handler: Arc<dyn MessageHandler<T>>, ) -> Self

Create a new builder wrapping the given consumer and handler.

pub fn with_metrics(self, metrics: Arc<dyn MetricsCollector>) -> Self

Set the metrics collector.

pub fn with_recv_backoff(self, recv_backoff: RetryPolicy) -> Self

Set the retry/backoff policy used after receive errors.

pub fn build(self) -> ManagedConsumer<T>

Build the managed consumer.