wow-spring-boot-starter/me.ahoo.wow.spring.boot.starter.eventsourcing.state/StateAutoConfiguration

StateAutoConfiguration

@AutoConfiguration

@EnableConfigurationProperties(value = [StateProperties::class])

class StateAutoConfiguration

Constructors

StateAutoConfiguration

constructor()

Types

object Companion

Functions

inMemoryStateEventBus

@Bean

@ConditionalOnProperty(value = ["wow.eventsourcing.state.bus.type"], havingValue = "in_memory")

fun inMemoryStateEventBus(): StateEventBus

localFirstStateEventBus

@Bean

@Primary

@ConditionalOnBean(value = [LocalStateEventBus::class, DistributedStateEventBus::class])

fun localFirstStateEventBus(localBus: LocalStateEventBus, distributedBus: DistributedStateEventBus, @Qualifier(value = "localFirstStateEventBusDistributedCopies") distributedCopies: LocalFirstDistributedCopies): LocalFirstStateEventBus

localFirstStateEventBusDistributedCopies

@Bean(value = ["localFirstStateEventBusDistributedCopies"])

@ConditionalOnBean(value = [DistributedStateEventBus::class])

@Order(value = 50)

fun localFirstStateEventBusDistributedCopies(stateProperties: StateProperties, metrics: ObjectProvider<WowMetrics>): LocalFirstDistributedCopies

The distributed copies of LocalFirstStateEventBus, its own bean so a decorated bus never hides it: a runtime component stopped after the dispatchers and before the transports.

localStateEventBus

@Bean

@ConditionalOnMissingBean(value = [LocalStateEventBus::class])

@ConditionalOnBean(value = [DistributedStateEventBus::class])

fun localStateEventBus(): LocalStateEventBus

stateEventCompensator

@Bean

fun stateEventCompensator(stateAggregateFactory: StateAggregateFactory, eventStore: EventStore, stateEventBus: StateEventBus): StateEventCompensator