wow-spring-boot-starter/me.ahoo.wow.spring.boot.starter.webflux/WebFluxAutoConfiguration

WebFluxAutoConfiguration

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

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

@ConditionalOnClass(name = ["org.springframework.web.server.WebFilter", "me.ahoo.wow.webflux.route.command.CommandHandlerFunction"])

class WebFluxAutoConfiguration

WebFlux Auto Configuration .

Author

ahoo wang

Constructors

WebFluxAutoConfiguration

constructor()

Types

Companion

object Companion

Functions

aggregateTracingHandlerFunctionFactory

@Bean

@Order(value = -2147483648)

@ConditionalOnMissingBean(name = ["aggregateTracingHandlerFunctionFactory"])

fun aggregateTracingHandlerFunctionFactory(eventStore: EventStore, exceptionHandler: RequestExceptionHandler): AggregateTracingHandlerFunctionFactory

batchRegenerateSnapshotHandlerFunctionFactory

@Bean

@Order(value = -2147483648)

@ConditionalOnMissingBean(name = ["batchRegenerateSnapshotHandlerFunctionFactory"])

fun batchRegenerateSnapshotHandlerFunctionFactory(stateAggregateFactory: StateAggregateFactory, eventStore: EventStore, snapshotRepository: SnapshotRepository, exceptionHandler: RequestExceptionHandler): BatchRegenerateSnapshotHandlerFunctionFactory

commandFacadeHandlerFunctionFactory

@Bean

@Order(value = -2147483648)

@ConditionalOnMissingBean(name = ["commandFacadeHandlerFunctionFactory"])

fun commandFacadeHandlerFunctionFactory(commandGateway: CommandGateway, commandMessageFactory: CommandMessageFactory, exceptionHandler: RequestExceptionHandler): CommandFacadeHandlerFunctionFactory

commandHandlerFunctionFactory

@Bean

@Order(value = -2147483648)

@ConditionalOnMissingBean(name = ["commandHandlerFunctionFactory"])

fun commandHandlerFunctionFactory(commandGateway: CommandGateway, commandMessageFactory: CommandMessageFactory, exceptionHandler: RequestExceptionHandler): CommandHandlerFunctionFactory

commandRouterFunction

@Bean

fun commandRouterFunction(routerSpecs: RouterSpecs, routeHandlerFunctionRegistrar: RouteHandlerFunctionRegistrar): RouterFunction<ServerResponse>

commandWaitHandlerFunctionFactory

@Bean

@Order(value = -2147483648)

@ConditionalOnMissingBean(name = ["commandWaitHandlerFunctionFactory"])

fun commandWaitHandlerFunctionFactory(waitStrategyRegistrar: WaitStrategyRegistrar): CommandWaitHandlerFunctionFactory

countSnapshotHandlerFunctionFactory

@Bean

@Order(value = -2147483648)

@ConditionalOnMissingBean(name = ["countSnapshotHandlerFunctionFactory"])

fun countSnapshotHandlerFunctionFactory(snapshotQueryHandler: SnapshotQueryHandler, exceptionHandler: RequestExceptionHandler): CountSnapshotHandlerFunctionFactory

eventCompensateHandlerFunctionFactory

@Bean

@Order(value = -2147483648)

@ConditionalOnMissingBean(name = ["eventCompensateHandlerFunctionFactory"])

fun eventCompensateHandlerFunctionFactory(eventCompensateSupporter: EventCompensateSupporter, exceptionHandler: RequestExceptionHandler): EventCompensateHandlerFunctionFactory

exceptionHandler

@Bean

@ConditionalOnMissingBean

fun exceptionHandler(): RequestExceptionHandler

generateBIScriptHandlerFunctionFactory

@Bean

@Order(value = -2147483648)

@ConditionalOnMissingBean(name = ["generateBIScriptHandlerFunctionFactory"])

fun generateBIScriptHandlerFunctionFactory(@Nullable kafkaProperties: KafkaProperties?): GenerateBIScriptHandlerFunctionFactory

getWowMetadataHandlerFunctionFactory

@Bean

@Order(value = -2147483648)

@ConditionalOnMissingBean(name = ["getWowMetadataHandlerFunctionFactory"])

fun getWowMetadataHandlerFunctionFactory(): GetWowMetadataHandlerFunctionFactory

globalExceptionHandler

@Bean

fun globalExceptionHandler(): WebExceptionHandler

globalIdHandlerFunctionFactory

@Bean

@Order(value = -2147483648)

@ConditionalOnMissingBean(name = ["globalIdHandlerFunctionFactory"])

fun globalIdHandlerFunctionFactory(): GlobalIdHandlerFunctionFactory

idsQueryAggregateHandlerFunctionFactory

@Bean

@Order(value = -2147483648)

@ConditionalOnMissingBean(name = ["idsQueryAggregateHandlerFunctionFactory"])

fun idsQueryAggregateHandlerFunctionFactory(stateAggregateRepository: StateAggregateRepository, exceptionHandler: RequestExceptionHandler): IdsQueryAggregateHandlerFunctionFactory

listQueryEventStreamHandlerFunctionFactory

@Bean

@Order(value = -2147483648)

@ConditionalOnMissingBean(name = ["listQueryEventStreamHandlerFunctionFactory"])

fun listQueryEventStreamHandlerFunctionFactory(eventStreamQueryServiceFactoryProvider: ObjectProvider<EventStreamQueryServiceFactory>, exceptionHandler: RequestExceptionHandler): ListQueryEventStreamHandlerFunctionFactory

listQuerySnapshotHandlerFunctionFactory

@Bean

@Order(value = -2147483648)

@ConditionalOnMissingBean(name = ["listQuerySnapshotHandlerFunctionFactory"])

fun listQuerySnapshotHandlerFunctionFactory(snapshotQueryHandler: SnapshotQueryHandler, exceptionHandler: RequestExceptionHandler): ListQuerySnapshotHandlerFunctionFactory

listQuerySnapshotStateHandlerFunctionFactory

@Bean

@Order(value = -2147483648)

@ConditionalOnMissingBean(name = ["listQuerySnapshotStateHandlerFunctionFactory"])

fun listQuerySnapshotStateHandlerFunctionFactory(snapshotQueryHandler: SnapshotQueryHandler, exceptionHandler: RequestExceptionHandler): ListQuerySnapshotStateHandlerFunctionFactory

loadAggregateHandlerFunctionFactory

@Bean

@Order(value = -2147483648)

@ConditionalOnMissingBean(name = ["loadAggregateHandlerFunctionFactory"])

fun loadAggregateHandlerFunctionFactory(stateAggregateRepository: StateAggregateRepository, exceptionHandler: RequestExceptionHandler): LoadAggregateHandlerFunctionFactory

loadEventStreamHandlerFunctionFactory

@Bean

@Order(value = -2147483648)

@ConditionalOnMissingBean(name = ["loadEventStreamHandlerFunctionFactory"])

fun loadEventStreamHandlerFunctionFactory(eventStore: EventStore, exceptionHandler: RequestExceptionHandler): LoadEventStreamHandlerFunctionFactory

loadSnapshotHandlerFunctionFactory

@Bean

@Order(value = -2147483648)

@ConditionalOnMissingBean(name = ["loadSnapshotHandlerFunctionFactory"])

fun loadSnapshotHandlerFunctionFactory(snapshotRepository: SnapshotRepository, exceptionHandler: RequestExceptionHandler): LoadSnapshotHandlerFunctionFactory

loadVersionedAggregateHandlerFunctionFactory

@Bean

@Order(value = -2147483648)

@ConditionalOnMissingBean(name = ["loadVersionedAggregateHandlerFunctionFactory"])

fun loadVersionedAggregateHandlerFunctionFactory(stateAggregateRepository: StateAggregateRepository, exceptionHandler: RequestExceptionHandler): LoadVersionedAggregateHandlerFunctionFactory

pagedQuerySnapshotHandlerFunctionFactory

@Bean

@Order(value = -2147483648)

@ConditionalOnMissingBean(name = ["pagedQuerySnapshotHandlerFunctionFactory"])

fun pagedQuerySnapshotHandlerFunctionFactory(snapshotQueryHandler: SnapshotQueryHandler, exceptionHandler: RequestExceptionHandler): PagedQuerySnapshotHandlerFunctionFactory

pagedQuerySnapshotStateHandlerFunctionFactory

@Bean

@Order(value = -2147483648)

@ConditionalOnMissingBean(name = ["pagedQuerySnapshotStateHandlerFunctionFactory"])

fun pagedQuerySnapshotStateHandlerFunctionFactory(snapshotQueryHandler: SnapshotQueryHandler, exceptionHandler: RequestExceptionHandler): PagedQuerySnapshotStateHandlerFunctionFactory

regenerateSnapshotHandlerFunctionFactory

@Bean

@Order(value = -2147483648)

@ConditionalOnMissingBean(name = ["regenerateSnapshotHandlerFunctionFactory"])

fun regenerateSnapshotHandlerFunctionFactory(stateAggregateFactory: StateAggregateFactory, eventStore: EventStore, snapshotRepository: SnapshotRepository, exceptionHandler: RequestExceptionHandler): RegenerateSnapshotHandlerFunctionFactory

resendStateEventFunctionFactory

@Bean

@Order(value = -2147483648)

@ConditionalOnMissingBean(name = ["resendStateEventFunctionFactory"])

fun resendStateEventFunctionFactory(snapshotRepository: SnapshotRepository, stateEventCompensator: StateEventCompensator, exceptionHandler: RequestExceptionHandler): ResendStateEventFunctionFactory

routeHandlerFunctionRegistrar

@Bean

fun routeHandlerFunctionRegistrar(factories: ObjectProvider<RouteHandlerFunctionFactory<*>>): RouteHandlerFunctionRegistrar

scanAggregateHandlerFunctionFactory

@Bean

@Order(value = -2147483648)

@ConditionalOnMissingBean(name = ["scanAggregateHandlerFunctionFactory"])

fun scanAggregateHandlerFunctionFactory(stateAggregateRepository: StateAggregateRepository, snapshotRepository: SnapshotRepository, exceptionHandler: RequestExceptionHandler): ScanAggregateHandlerFunctionFactory

singleSnapshotHandlerFunctionFactory

@Bean

@Order(value = -2147483648)

@ConditionalOnMissingBean(name = ["singleSnapshotHandlerFunctionFactory"])

fun singleSnapshotHandlerFunctionFactory(snapshotQueryHandler: SnapshotQueryHandler, exceptionHandler: RequestExceptionHandler): SingleSnapshotHandlerFunctionFactory

singleSnapshotStateHandlerFunctionFactory

@Bean

@Order(value = -2147483648)

@ConditionalOnMissingBean(name = ["singleSnapshotStateHandlerFunctionFactory"])

fun singleSnapshotStateHandlerFunctionFactory(snapshotQueryHandler: SnapshotQueryHandler, exceptionHandler: RequestExceptionHandler): SingleSnapshotStateHandlerFunctionFactory