wow-spring-boot-starter/me.ahoo.wow.spring.boot.starter.modeling/AggregateAutoConfiguration

AggregateAutoConfiguration

@AutoConfiguration

class AggregateAutoConfiguration

Constructors

constructor()

Functions

aggregateDispatcher

@Bean

@ConditionalOnMissingBean

fun aggregateDispatcher(@Qualifier(value = "wow.CurrentBoundedContext") namedBoundedContext: NamedBoundedContext, commandBus: CommandGateway, aggregateProcessorFactory: AggregateProcessorFactory, commandHandler: CommandHandler, serviceProvider: ServiceProvider): CommandDispatcher

aggregateDispatcherLauncher

@Bean

@ConditionalOnMissingBean

fun aggregateDispatcherLauncher(commandDispatcher: CommandDispatcher): CommandDispatcherLauncher

aggregateProcessorFactory

@Bean

@ConditionalOnMissingBean

fun aggregateProcessorFactory(stateAggregateFactory: StateAggregateFactory, stateAggregateRepository: StateAggregateRepository, commandAggregateFactory: CommandAggregateFactory): AggregateProcessorFactory

aggregateProcessorFilter

@Bean

@ConditionalOnMissingBean

fun aggregateProcessorFilter(): AggregateProcessorFilter

commandAggregateFactory

@Bean

@ConditionalOnMissingBean

fun commandAggregateFactory(eventStore: EventStore): CommandAggregateFactory

commandErrorHandler

@Bean(value = ["commandErrorHandler"])

@ConditionalOnMissingBean(name = ["commandErrorHandler"])

fun commandErrorHandler(): ErrorHandler<ServerCommandExchange<*>>

commandFilterChain

@Bean

fun commandFilterChain(filters: List<ExchangeFilter<ServerCommandExchange<*>>>): FilterChain<ServerCommandExchange<*>>

commandHandler

@Bean

@ConditionalOnMissingBean

fun commandHandler(commandFilterChain: FilterChain<ServerCommandExchange<*>>, @Qualifier(value = "commandErrorHandler") commandErrorHandler: ErrorHandler<ServerCommandExchange<*>>): CommandHandler

sendDomainEventStreamFilter

@Bean

@ConditionalOnMissingBean

fun sendDomainEventStreamFilter(domainEventBus: DomainEventBus): SendDomainEventStreamFilter

stateAggregateFactory

@Bean

@ConditionalOnMissingBean

fun stateAggregateFactory(): StateAggregateFactory

stateAggregateRepository

@Bean

@ConditionalOnMissingBean

fun stateAggregateRepository(stateAggregateFactory: StateAggregateFactory, snapshotRepository: SnapshotRepository, eventStore: EventStore): StateAggregateRepository