Struct ContainerConsumer 

pub struct ContainerConsumer { /* private fields */ }

Consumer for receiving Docker container events or logs.

This consumer subscribes to Docker events or container logs and forwards them to the route as exchanges. It implements automatic reconnection on connection failures.

Trait Implementations

impl Consumer for ContainerConsumer

fn start<'life0, 'async_trait>( &'life0 mut self, context: ConsumerContext, ) -> Pin<Box<dyn Future<Output = Result<(), CamelError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Start consuming messages, sending them through the provided context.

fn stop<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<(), CamelError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Stop consuming messages.

fn concurrency_model(&self) -> ConcurrencyModel

Declares this consumer’s natural concurrency model.