Struct LocalEventBusFactory 

pub struct LocalEventBusFactory { /* private fields */ }

Factory used to create LocalEventBus instances with default options.

Implementations

impl LocalEventBusFactory

pub fn new() -> Self

Creates an empty local event bus factory.

Returns

Factory with no typed defaults.

pub fn set_default_publish_options<T>(&mut self, options: PublishOptions<T>)

where T: Send + Sync + 'static,

Sets default publish options for a payload type.

Parameters

• options: Options used by default publish methods for payload T.

pub fn set_default_subscribe_options<T>(&mut self, options: SubscribeOptions<T>)

where T: Send + Sync + 'static,

Sets default subscribe options for a payload type.

Parameters

• options: Options used by LocalEventBus::subscribe for payload T.

pub fn set_default_dead_letter_strategy<T, F>(&mut self, strategy: F)

where T: Clone + Send + Sync + 'static, F: DeadLetterStrategyCallback<T>,

Sets the default dead-letter strategy for a payload type.

Parameters

• strategy: Strategy used when subscription options do not provide one.

pub fn set_global_default_dead_letter_strategy<F>(&mut self, strategy: F)

where F: DeadLetterStrategyAnyCallback,

Sets the global default dead-letter strategy.

Parameters

• strategy: Strategy used when no subscription or typed factory dead-letter strategy is configured.

pub fn add_publisher_interceptor<T, I>( &mut self, interceptor: I, ) -> EventBusResult<()>

where T: Clone + Send + Sync + 'static, I: PublisherInterceptor<T>,

Adds a publisher interceptor to buses created by this factory.

Parameters

• interceptor: Callback that can modify or drop outgoing envelopes.

Returns

Ok(()) when the interceptor is stored.

pub fn add_global_publisher_interceptor<I>( &mut self, interceptor: I, ) -> EventBusResult<()>

where I: PublisherInterceptorAny,

Adds a global publisher interceptor to buses created by this factory.

Parameters

• interceptor: Callback that can mutate metadata or drop any event.

Returns

Ok(()) when the interceptor is stored.

pub fn add_subscriber_interceptor<T, I>( &mut self, interceptor: I, ) -> EventBusResult<()>

where T: Clone + Send + Sync + 'static, I: SubscriberInterceptor<T>,

Adds a subscriber interceptor to buses created by this factory.

Parameters

• interceptor: Callback wrapping subscriber handler execution.

Returns

Ok(()) when the interceptor is stored.

pub fn add_global_subscriber_interceptor<I>( &mut self, interceptor: I, ) -> EventBusResult<()>

where I: SubscriberInterceptorAny,

Adds a global subscriber interceptor to buses created by this factory.

Parameters

• interceptor: Callback wrapping subscriber handling for any payload type.

Returns

Ok(()) when the interceptor is stored.

pub fn set_subscription_handler_pool_size( &mut self, pool_size: usize, ) -> EventBusResult<()>

Sets the subscription handler worker count for created buses.

Parameters

• pool_size: Number of worker threads used for subscriber handlers.

Returns

Ok(()) when the value is stored.

Errors

Returns EventBusError::InvalidArgument when pool_size is zero.

pub fn set_subscription_handler_queue_capacity( &mut self, capacity: Option<usize>, ) -> EventBusResult<()>

Sets the optional subscription handler queue capacity.

Parameters

• capacity: Maximum queued subscriber tasks, or None for unbounded.

Returns

Ok(()) when the value is stored.

Errors

Returns EventBusError::InvalidArgument when a configured capacity is zero.

pub fn create(&self) -> LocalEventBus

Creates a stopped event bus.

Returns

Local event bus initialized with factory defaults.

pub fn create_started(&self) -> EventBusResult<LocalEventBus>

Creates and starts an event bus.

Returns

Started local event bus initialized with factory defaults.

Errors

Returns startup errors from the handler executor.

Trait Implementations

impl Default for LocalEventBusFactory

fn default() -> Self

Creates an empty local event bus factory with default runtime options.

impl EventBusFactory for LocalEventBusFactory

fn is_transactional_supported(&self) -> bool

Local event bus does not support transactional operations.

fn create(&self) -> Self::Bus

Creates a stopped local event bus.

fn create_started(&self) -> EventBusResult<Self::Bus>

Creates and starts a local event bus.

fn set_default_publish_options<T>( &mut self, options: PublishOptions<T>, ) -> EventBusResult<()>

where T: Send + Sync + 'static,

Sets typed default publish options for local buses.

fn set_default_subscribe_options<T>( &mut self, options: SubscribeOptions<T>, ) -> EventBusResult<()>

where T: Send + Sync + 'static,

Sets typed default subscribe options for local buses.

fn set_default_dead_letter_strategy<T, F>( &mut self, strategy: F, ) -> EventBusResult<()>

where T: Clone + Send + Sync + 'static, F: DeadLetterStrategyCallback<T>,

Sets a typed default dead-letter strategy for local buses.

fn set_global_default_dead_letter_strategy<F>( &mut self, strategy: F, ) -> EventBusResult<()>

where F: DeadLetterStrategyAnyCallback,

Sets the global default dead-letter strategy for local buses.

fn add_publisher_interceptor<T, I>( &mut self, interceptor: I, ) -> EventBusResult<()>

where T: Clone + Send + Sync + 'static, I: PublisherInterceptor<T>,

Adds a typed publisher interceptor for local buses.

fn add_global_publisher_interceptor<I>( &mut self, interceptor: I, ) -> EventBusResult<()>

where I: PublisherInterceptorAny,

Adds a global publisher interceptor for local buses.

fn add_subscriber_interceptor<T, I>( &mut self, interceptor: I, ) -> EventBusResult<()>

where T: Clone + Send + Sync + 'static, I: SubscriberInterceptor<T>,

Adds a typed subscriber interceptor for local buses.

fn add_global_subscriber_interceptor<I>( &mut self, interceptor: I, ) -> EventBusResult<()>

where I: SubscriberInterceptorAny,

Adds a global subscriber interceptor for local buses.

type Bus = LocalEventBus

Concrete event bus created by this factory.

type TransactionalBus = UnsupportedTransactionalEventBus

Transactional event bus type returned when the backend supports it.

fn create_transactional(&self) -> EventBusResult<Self::TransactionalBus>

Creates a transactional event bus.