Struct WasmSourceConsumer 

pub struct WasmSourceConsumer { /* private fields */ }

Consumer backed by a WASM source world component.

Implementations

impl WasmSourceConsumer

pub fn new( module_path: PathBuf, config: WasmConfig, guest_config: Vec<(String, String)>, registry: Arc<Mutex<Registry>>, ) -> Self

Trait Implementations

impl Consumer for WasmSourceConsumer

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.