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

AggregateAutoConfiguration

@AutoConfiguration

class AggregateAutoConfiguration

Constructors

AggregateAutoConfiguration

constructor()

Functions

aggregateDispatcher

@Bean

@ConditionalOnMissingBean

@Order(value = 100)

fun aggregateDispatcher(@Qualifier(value = "wow.CurrentBoundedContext") namedBoundedContext: NamedBoundedContext, commandBus: CommandGateway, commandHandler: CommandHandler, metrics: ObjectProvider<WowMetrics>): CommandDispatcher

aggregateProcessorFactory

@Bean

@ConditionalOnMissingBean

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

commandAggregateFactory

@Bean

@ConditionalOnMissingBean

fun commandAggregateFactory(eventStore: EventStore, messagePropagators: ObjectProvider<MessagePropagators>): CommandAggregateFactory

commandErrorHandler

@Bean(value = ["commandErrorHandler"])

@ConditionalOnMissingBean(name = ["commandErrorHandler"])

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

@Bean

@ConditionalOnMissingBean

fun commandHandler(serviceProvider: ServiceProvider, aggregateProcessorFactory: AggregateProcessorFactory, domainEventBus: DomainEventBus, stateEventBus: ObjectProvider<StateEventBus>, commandWaitNotifier: ObjectProvider<CommandWaitNotifier>, instrumentations: ObjectProvider<CommandInstrumentation>, commandProperties: ObjectProvider<CommandProperties>, eventStore: ObjectProvider<EventStore>, @Qualifier(value = "commandErrorHandler") commandErrorHandler: ErrorHandler<ServerCommandExchange<*>>): CommandHandler

retiredCommandFilterCheck

@Bean

fun retiredCommandFilterCheck(beanFactory: ConfigurableListableBeanFactory): SmartInitializingSingleton

stateAggregateFactory

@Bean

@ConditionalOnMissingBean

fun stateAggregateFactory(): StateAggregateFactory

stateAggregateRepository

@Bean

@ConditionalOnMissingBean

fun stateAggregateRepository(stateAggregateFactory: StateAggregateFactory, snapshotStore: SnapshotStore, eventStore: EventStore): StateAggregateRepository