Struct ManagedConsumer 

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

Wraps a MessageConsumer with lifecycle, handler dispatch, and graceful shutdown.

Use ManagedConsumerBuilder to construct an instance.

Implementations

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

pub fn name(&self) -> &str

Returns the name of this managed consumer.

pub fn is_running(&self) -> bool

Returns true when the consumer loop is running.

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

Start the consumption loop in a background tokio task.

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

Stop the consumption loop and wait for it to drain.