Struct CronConsumer 

pub struct CronConsumer { /* private fields */ }

Consumer that fires Exchanges on a cron schedule.

Implementations

impl CronConsumer

pub fn new(config: CronConfig, service: Arc<dyn CronService>) -> Self

Create a new CronConsumer with the given config and scheduling service.

Trait Implementations

impl Consumer for CronConsumer

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 and clean up all resources.

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 concurrency_model(&self) -> ConcurrencyModel

Declares this consumer’s natural concurrency model.

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.