Struct JmsConsumer 

pub struct JmsConsumer { /* private fields */ }

Implementations

impl JmsConsumer

pub fn new( pool: Arc<JmsBridgePool>, broker_name: String, endpoint_config: JmsEndpointConfig, reconnect: NetworkRetryPolicy, runtime: Arc<dyn RuntimeObservability>, ) -> Self

Trait Implementations

impl Consumer for JmsConsumer

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 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 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 set_security_context(&mut self, _ctx: SecurityContext)

Set the security context for this consumer.