wow-spring-boot-starter/me.ahoo.wow.spring.boot.starter.command/CommandGatewayAutoConfiguration

CommandGatewayAutoConfiguration

@AutoConfiguration(after = [CommandAutoConfiguration::class])

Constructors

constructor()

Functions

fun commandGateway(commandWaitEndpoint: CommandWaitEndpoint, commandBus: CommandBus, validator: Validator, requestIdChecker: RequestIdChecker, waitCoordinator: WaitCoordinator, commandWaitNotifier: CommandWaitNotifier): CommandGateway

Retains the direct factory signature for source and binary compatibility.

commandGatewayBean

@Bean(value = ["commandGateway"])

@Primary

@ConditionalOnMissingBean

fun commandGatewayBean(commandWaitEndpoint: CommandWaitEndpoint, commandBus: ObjectProvider<CommandBus>, validator: Validator, requestIdChecker: RequestIdChecker, waitCoordinator: WaitCoordinator, commandWaitNotifier: CommandWaitNotifier): CommandGateway

commandWaitEndpoint

@Bean

@ConditionalOnMissingBean

fun commandWaitEndpoint(hostAddressSupplier: HostAddressSupplier): CommandWaitEndpoint

commandWaitNotifier

@Bean

@ConditionalOnMissingClass(value = ["me.ahoo.wow.webflux.route.command.CommandHandlerFunction"])

fun commandWaitNotifier(waitCoordinator: WaitCoordinator): CommandWaitNotifier

eventHandledNotifierFilter

@Bean

fun eventHandledNotifierFilter(commandWaitNotifier: CommandWaitNotifier): EventHandledNotifierFilter

idempotencyChecker

@Bean

@ConditionalOnMissingBean

@ConditionalOnProperty(value = ["wow.command.idempotency.enabled"], matchIfMissing = true, havingValue = "true")

fun idempotencyChecker(commandProperties: CommandProperties): AggregateIdempotencyCheckerProvider

noOpIdempotencyCheckerProvider

@Bean

@ConditionalOnMissingBean

@ConditionalOnProperty(value = ["wow.command.idempotency.enabled"], matchIfMissing = false, havingValue = "false")

fun noOpIdempotencyCheckerProvider(): AggregateIdempotencyCheckerProvider

processedNotifierFilter

@Bean

fun processedNotifierFilter(commandWaitNotifier: CommandWaitNotifier): ProcessedNotifierFilter

projectedNotifierFilter

@Bean

fun projectedNotifierFilter(commandWaitNotifier: CommandWaitNotifier): ProjectedNotifierFilter

requestIdChecker

@Bean

@ConditionalOnMissingBean

fun requestIdChecker(idempotencyCheckerProvider: AggregateIdempotencyCheckerProvider, requestIdExistenceCheckerProvider: ObjectProvider<RequestIdExistenceChecker>): RequestIdChecker

sagaHandledNotifierFilter

@Bean

fun sagaHandledNotifierFilter(commandWaitNotifier: CommandWaitNotifier): SagaHandledNotifierFilter

snapshotNotifierFilter

@Bean

fun snapshotNotifierFilter(commandWaitNotifier: CommandWaitNotifier): SnapshotNotifierFilter

waitCoordinator

@Bean

@ConditionalOnMissingBean

fun waitCoordinator(): WaitCoordinator