Struct WsConsumer 

pub struct WsConsumer { /* private fields */ }

Implementations

impl WsConsumer

pub fn new(cfg: WsServerConfig, runtime: Arc<dyn RuntimeObservability>) -> Self

Trait Implementations

impl Consumer for WsConsumer

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

Set the security context for this consumer.

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.