wow-spring-boot-starter/me.ahoo.wow.spring.boot.starter.mongo/MongoEventSourcingAutoConfiguration

MongoEventSourcingAutoConfiguration

@AutoConfiguration(after = [WowAutoConfiguration::class, MongoReactiveAutoConfiguration::class])

@ConditionalOnClass(value = [MongoEventStore::class])

@EnableConfigurationProperties(value = [MongoProperties::class, MongoEventStoreBatchProperties::class, MongoSnapshotStoreBatchProperties::class])

class MongoEventSourcingAutoConfiguration @Autowired constructor(mongoProperties: MongoProperties, eventStoreBatchProperties: MongoEventStoreBatchProperties, snapshotStoreBatchProperties: MongoSnapshotStoreBatchProperties)

Constructors

MongoEventSourcingAutoConfiguration

@Autowired

constructor(mongoProperties: MongoProperties, eventStoreBatchProperties: MongoEventStoreBatchProperties, snapshotStoreBatchProperties: MongoSnapshotStoreBatchProperties)

constructor(mongoProperties: MongoProperties)

constructor(mongoProperties: MongoProperties, eventStoreBatchProperties: MongoEventStoreBatchProperties)

Functions

mongoEventStore

@Bean

@ConditionalOnEventStoreStorage(value = StorageType.MONGO)

fun mongoEventStore(mongoClient: MongoClient, dataMongoProperties: MongoProperties?, @Qualifier(value = "wow.CurrentBoundedContext") currentBoundedContext: NamedBoundedContext): MongoEventStore

mongoEventStoreBinding

@Bean

@ConditionalOnEventStoreStorage(value = StorageType.MONGO)

fun mongoEventStoreBinding(@Qualifier(value = "mongoEventStore") eventStore: EventStore): EventStoreBinding

mongoEventStreamQueryServiceFactory

@Bean

@ConditionalOnEventStoreStorage(value = StorageType.MONGO)

fun mongoEventStreamQueryServiceFactory(mongoClient: MongoClient, dataMongoProperties: MongoProperties?, @Qualifier(value = "wow.CurrentBoundedContext") currentBoundedContext: NamedBoundedContext): MongoEventStreamQueryServiceFactory

mongoEventStreamQueryServiceFactoryBinding

@Bean

@ConditionalOnEventStoreStorage(value = StorageType.MONGO)

fun mongoEventStreamQueryServiceFactoryBinding(mongoEventStreamQueryServiceFactory: MongoEventStreamQueryServiceFactory): EventStreamQueryServiceFactoryBinding

mongoPrepareKeyFactory

@Bean

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

@ConditionalOnProperty(value = ["wow.prepare.storage"], matchIfMissing = true, havingValue = "mongo")

@ConditionalOnMissingBean

fun mongoPrepareKeyFactory(mongoClient: MongoClient, dataMongoProperties: MongoProperties?, @Qualifier(value = "wow.CurrentBoundedContext") currentBoundedContext: NamedBoundedContext): PrepareKeyFactory

mongoSnapshotQueryServiceFactory

@Bean

@ConditionalOnSnapshotStoreStorage(value = StorageType.MONGO)

fun mongoSnapshotQueryServiceFactory(mongoClient: MongoClient, dataMongoProperties: MongoProperties?, @Qualifier(value = "wow.CurrentBoundedContext") currentBoundedContext: NamedBoundedContext): MongoSnapshotQueryServiceFactory

mongoSnapshotQueryServiceFactoryBinding

@Bean

@ConditionalOnSnapshotStoreStorage(value = StorageType.MONGO)

fun mongoSnapshotQueryServiceFactoryBinding(mongoSnapshotQueryServiceFactory: MongoSnapshotQueryServiceFactory): SnapshotQueryServiceFactoryBinding

mongoSnapshotStore

@Bean(name = ["mongoSnapshotStore", "mongoSnapshotRepository"])

@ConditionalOnSnapshotStoreStorage(value = StorageType.MONGO)

fun mongoSnapshotStore(mongoClient: MongoClient, dataMongoProperties: MongoProperties?, @Qualifier(value = "wow.CurrentBoundedContext") currentBoundedContext: NamedBoundedContext): MongoSnapshotStore

mongoSnapshotStoreBinding

@Bean

@ConditionalOnSnapshotStoreStorage(value = StorageType.MONGO)

fun mongoSnapshotStoreBinding(@Qualifier(value = "mongoSnapshotStore") snapshotStore: SnapshotStore): SnapshotStoreBinding