Struct ConsumerRunner 

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

Manages the consumption loop as a tokio task.

Unlike ManagedConsumer, ConsumerRunner owns the task handle directly and provides a simpler run/stop interface without builder overhead.

Implementations

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

pub fn new( consumer: Arc<dyn MessageConsumer<T>>, handler: Arc<dyn MessageHandler<T>>, ) -> Self

Create a new runner for the given consumer and handler.

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

Set the metrics collector.

pub const fn with_shutdown_timeout(self, timeout: Duration) -> Self

Set the graceful shutdown timeout.

pub fn is_running(&self) -> bool

Returns true when the consumption loop is running.

pub fn run(&self) -> AppResult<()>

Start the consumption loop.

pub async fn stop(&self) -> AppResult<()>

Stop the consumption loop and wait for it to finish.