wow-spring-boot-starter/me.ahoo.wow.spring.boot.starter.event/EventDispatcherAutoConfiguration

EventDispatcherAutoConfiguration

@AutoConfiguration

class EventDispatcherAutoConfiguration

Constructors

EventDispatcherAutoConfiguration

constructor()

Functions

domainEventDispatcher

@Bean

@ConditionalOnMissingBean

fun domainEventDispatcher(@Qualifier(value = "wow.CurrentBoundedContext") namedBoundedContext: NamedBoundedContext, domainEventBus: DomainEventBus, stateEventBus: StateEventBus, handlerRegistrar: DomainEventFunctionRegistrar, eventDispatcherHandler: DomainEventHandler): DomainEventDispatcher

domainEventDispatcherLauncher

@Bean

@ConditionalOnMissingBean

fun domainEventDispatcherLauncher(domainEventDispatcher: DomainEventDispatcher): DomainEventDispatcherLauncher

domainEventHandlerRegistrar

@Bean

fun domainEventHandlerRegistrar(): DomainEventFunctionRegistrar

eventDispatcherFilterChain

@Bean

fun eventDispatcherFilterChain(filters: List<ExchangeFilter<DomainEventExchange<*>>>): FilterChain<DomainEventExchange<*>>

eventDispatcherFunctionFilter

@Bean

fun eventDispatcherFunctionFilter(serviceProvider: ServiceProvider): DomainEventFunctionFilter

eventDispatcherHandler

@Bean

fun eventDispatcherHandler(@Qualifier(value = "eventDispatcherFilterChain") chain: FilterChain<DomainEventExchange<*>>, @Qualifier(value = "eventProcessorErrorHandler") eventProcessorErrorHandler: ErrorHandler<DomainEventExchange<*>>): DomainEventHandler

eventDispatcherRetryableFilter

@Bean

fun eventDispatcherRetryableFilter(): RetryableFilter<DomainEventExchange<Any>>

eventProcessorAutoRegistrar

@Bean

fun eventProcessorAutoRegistrar(handlerRegistrar: DomainEventFunctionRegistrar, applicationContext: ApplicationContext): EventProcessorAutoRegistrar

eventProcessorErrorHandler

@Bean(value = ["eventProcessorErrorHandler"])

@ConditionalOnMissingBean(name = ["eventProcessorErrorHandler"])

fun eventProcessorErrorHandler(): ErrorHandler<DomainEventExchange<*>>