Struct BeanRegistry 

pub struct BeanRegistry { /* private fields */ }

A thread-safe registry for named bean processors.

Uses Arc<Mutex<...>> internally so that register() and lookup() can be called from multiple threads without external synchronisation.

Implementations

impl BeanRegistry

pub fn new() -> Self

pub fn register<B>( &self, name: impl Into<String>, bean: B, ) -> Result<(), BeanError>

where B: BeanProcessor + 'static,

Register a bean under the given name.

Returns Err(BeanError::DuplicateName) if a bean with the same name already exists, or Err(BeanError::InvalidName) if the name is blank.

pub fn get(&self, name: &str) -> Option<Arc<dyn BeanProcessor>>

pub async fn invoke( &self, bean_name: &str, method: &str, exchange: &mut Exchange, ) -> Result<(), CamelError>

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

Trait Implementations

impl Default for BeanRegistry

fn default() -> Self

Returns the “default value” for a type.