Struct MessagingRegistry 

pub struct MessagingRegistry<T: Send + Sync + 'static> { /* private fields */ }

Application-owned registry of messaging adapter factories.

Adapters are registered explicitly by application composition code. Importing an adapter module does not mutate global state or dial external services.

Implementations

impl<T: Send + Sync + 'static> MessagingRegistry<T>

pub fn new() -> Self

Create an empty messaging registry.

pub fn register_backend( &mut self, adapter: impl Into<String>, factory: Arc<dyn MessagingFactory<T>>, ) -> AppResult<()>

Register a backend factory under adapter.

pub fn build(&self, config: &BrokerConfig) -> AppResult<MessagingBackend<T>>

Build producer and consumer for BrokerConfig::adapter.

pub fn producer( &self, config: &BrokerConfig, ) -> AppResult<Arc<dyn MessageProducer<T>>>

Construct a producer for BrokerConfig::adapter.

pub fn consumer( &self, config: &BrokerConfig, ) -> AppResult<Arc<dyn MessageConsumer<T>>>

Construct a consumer for BrokerConfig::adapter.

pub fn adapters(&self) -> Vec<&str>

Return registered adapter names.

pub fn is_empty(&self) -> bool

Return true when no adapters are registered.

pub fn len(&self) -> usize

Number of registered adapters.

pub fn contains(&self, adapter: &str) -> bool

Return true when adapter is registered.

Trait Implementations

impl<T: Send + Sync + 'static> Default for MessagingRegistry<T>

fn default() -> Self

Returns the “default value” for a type.