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

CommandGatewayAutoConfiguration

@AutoConfiguration

class CommandGatewayAutoConfiguration

Constructors

constructor()

Functions

commandGateway

@Bean

@Primary

@ConditionalOnMissingBean

fun commandGateway(commandWaitEndpoint: CommandWaitEndpoint, commandBus: CommandBus, validator: Validator, idempotencyCheckerProvider: AggregateIdempotencyCheckerProvider, waitStrategyRegistrar: WaitStrategyRegistrar): CommandGateway

commandWaitEndpoint

@Bean

@ConditionalOnMissingBean

fun commandWaitEndpoint(hostAddressSupplier: HostAddressSupplier): CommandWaitEndpoint

commandWaitNotifier

@Bean

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

fun commandWaitNotifier(waitStrategyRegistrar: WaitStrategyRegistrar): 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

sagaHandledNotifierFilter

@Bean

fun sagaHandledNotifierFilter(commandWaitNotifier: CommandWaitNotifier): SagaHandledNotifierFilter

snapshotNotifierFilter

@Bean

fun snapshotNotifierFilter(commandWaitNotifier: CommandWaitNotifier): SnapshotNotifierFilter

waitStrategyRegistrar

@Bean

@ConditionalOnMissingBean

fun waitStrategyRegistrar(): WaitStrategyRegistrar