wow-spring-boot-starter/me.ahoo.wow.spring.boot.starter.eventsourcing.routing/StorageRoutingAutoConfiguration

StorageRoutingAutoConfiguration

@AutoConfiguration(after = [EventSourcingAutoConfiguration::class, EventStoreAutoConfiguration::class, SnapshotAutoConfiguration::class, MongoEventSourcingAutoConfiguration::class, RedisEventSourcingAutoConfiguration::class, ElasticsearchEventSourcingAutoConfiguration::class, MockEventStoreAutoConfiguration::class, MockSnapshotAutoConfiguration::class, QueryAutoConfiguration::class])

@EnableConfigurationProperties(value = [StorageRoutingProperties::class, EventStoreProperties::class, SnapshotProperties::class])

class StorageRoutingAutoConfiguration

Constructors

StorageRoutingAutoConfiguration

constructor()

Functions

routingEventStore

@Bean(destroyMethod = "")

@Primary

@Conditional(value = [OnEventStorageRouteCondition::class])

fun routingEventStore(@Qualifier(value = "wow.CurrentBoundedContext") namedBoundedContext: NamedBoundedContext, eventStoreProperties: EventStoreProperties, snapshotProperties: SnapshotProperties, storageRoutingProperties: StorageRoutingProperties, eventStoreBindings: List<EventStoreBinding>, snapshotStoreBindings: List<SnapshotStoreBinding>, queryBackendProviders: List<QueryBackendProvider>): EventStore

routingEventStreamQueryBackendFactory

@Bean

@Primary

@Conditional(value = [OnEventStorageRouteCondition::class])

fun routingEventStreamQueryBackendFactory(@Qualifier(value = "wow.CurrentBoundedContext") namedBoundedContext: NamedBoundedContext, eventStoreProperties: EventStoreProperties, snapshotProperties: SnapshotProperties, storageRoutingProperties: StorageRoutingProperties, eventStoreBindings: List<EventStoreBinding>, snapshotStoreBindings: List<SnapshotStoreBinding>, queryBackendProviders: List<QueryBackendProvider>): EventStreamQueryBackendFactory

routingSnapshotQueryBackendFactory

@Bean

@Primary

@Conditional(value = [OnSnapshotStorageRouteCondition::class])

fun routingSnapshotQueryBackendFactory(@Qualifier(value = "wow.CurrentBoundedContext") namedBoundedContext: NamedBoundedContext, eventStoreProperties: EventStoreProperties, snapshotProperties: SnapshotProperties, storageRoutingProperties: StorageRoutingProperties, eventStoreBindings: List<EventStoreBinding>, snapshotStoreBindings: List<SnapshotStoreBinding>, queryBackendProviders: List<QueryBackendProvider>): SnapshotQueryBackendFactory

routingSnapshotStore

@Bean(destroyMethod = "")

@Primary

@Conditional(value = [OnSnapshotStorageRouteCondition::class])

fun routingSnapshotStore(@Qualifier(value = "wow.CurrentBoundedContext") namedBoundedContext: NamedBoundedContext, eventStoreProperties: EventStoreProperties, snapshotProperties: SnapshotProperties, storageRoutingProperties: StorageRoutingProperties, eventStoreBindings: List<EventStoreBinding>, snapshotStoreBindings: List<SnapshotStoreBinding>, queryBackendProviders: List<QueryBackendProvider>): SnapshotStore

storageDefaultsValidation

@Bean

fun storageDefaultsValidation(environment: Environment): InitializingBean

Rejects a default channel that names both a built-in storage and a binding, as a route does: the two exclude each other, and silently preferring one would hide a misconfiguration.