Struct HttpStaticConsumer 

pub struct HttpStaticConsumer { /* private fields */ }

Consumer that registers a static file mount into the shared [HttpRouteRegistry] and stays idle until cancelled.

On start:

1. Canonicalizes the configured dir (fails if not found).
2. Canonicalizes each error_pages path (fails if any don’t exist).
3. Builds a ServeDir for the directory.
4. Registers a StaticMount into the registry.

On stop (cancellation):

• Unregisters the mount from the registry.

Implementations

impl HttpStaticConsumer

pub fn new( config: HttpStaticConfig, runtime: Arc<dyn RuntimeObservability>, ) -> Self

Create a new HttpStaticConsumer from the given config.

Trait Implementations

impl Consumer for HttpStaticConsumer

fn start<'life0, 'async_trait>( &'life0 mut self, ctx: 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 and clean up all resources.

fn concurrency_model(&self) -> ConcurrencyModel

Declares this consumer’s natural concurrency model.

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

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

Temporarily suspend consuming messages without fully stopping.

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

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

Resume consuming after a previous suspension.

fn background_task_handle( &mut self, ) -> Option<JoinHandle<Result<(), CamelError>>>

Return a handle to the consumer’s long-running background task so the runtime can monitor it for unexpected exits after start() returns Ok.

fn set_security_context(&mut self, _ctx: SecurityContext)

Set the security context for this consumer.