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()

Functions

batchExecutionPolicy

@Bean

@ConditionalOnMissingBean

fun batchExecutionPolicy(webFluxProperties: WebFluxProperties): BatchExecutionPolicy

commandBuilderExtractor

@Bean

@ConditionalOnMissingBean

fun commandBuilderExtractor(): CommandBuilderExtractor

commandMessageExtractor

@Bean

@ConditionalOnMissingBean

fun commandMessageExtractor(commandMessageFactory: CommandMessageFactory, commandBuilderExtractor: CommandBuilderExtractor, commandRequestHeaderAppenderObjectProvider: ObjectProvider<CommandRequestHeaderAppender>): CommandMessageExtractor

commandRequestExtendHeaderAppender

@Bean

fun commandRequestExtendHeaderAppender(): CommandRequestExtendHeaderAppender

commandRequestRemoteIpHeaderAppender

@Bean

@ConditionalOnProperty(value = ["wow.webflux.command.request.appender.ip.enabled"], matchIfMissing = true, havingValue = "true")

fun commandRequestRemoteIpHeaderAppender(): CommandRequestRemoteIpHeaderAppender

commandRequestUserAgentHeaderAppender

@Bean

@ConditionalOnProperty(value = ["wow.webflux.command.request.appender.agent.enabled"], matchIfMissing = true, havingValue = "true")

fun commandRequestUserAgentHeaderAppender(): CommandRequestUserAgentHeaderAppender

commandRouteModule

@Bean

@Order(value = -2147483648)

@ConditionalOnMissingBean

fun commandRouteModule(waitCoordinator: WaitCoordinator, commandGateway: CommandGateway, commandMessageExtractor: CommandMessageExtractor, exceptionHandler: RequestExceptionHandler, commandWaitPolicy: CommandWaitPolicy): CommandRouteModule

commandRouterFunction

@Bean

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

commandWaitPolicy

@Bean

@ConditionalOnMissingBean

fun commandWaitPolicy(): CommandWaitPolicy

eventRouteModule

@Bean

@Order(value = -2147483648)

@ConditionalOnMissingBean

fun eventRouteModule(snapshotRepository: SnapshotRepository, stateEventCompensator: StateEventCompensator, eventCompensateSupporter: EventCompensateSupporter, exceptionHandler: RequestExceptionHandler, batchExecutionPolicy: BatchExecutionPolicy): EventRouteModule

exceptionHandler

@Bean

@ConditionalOnMissingBean

fun exceptionHandler(errorStrategy: WebFluxErrorStrategy): RequestExceptionHandler

globalExceptionHandler

@Bean

fun globalExceptionHandler(errorStrategy: WebFluxErrorStrategy): WebExceptionHandler

globalRouteModule

@Bean

@Order(value = -2147483648)

@ConditionalOnMissingBean

fun globalRouteModule(kafkaProperties: ObjectProvider<KafkaProperties>): GlobalRouteModule

queryRouteModule

@Bean

@Order(value = -2147483648)

@ConditionalOnMissingBean

fun queryRouteModule(snapshotQueryHandler: SnapshotQueryHandler, eventStreamQueryHandler: EventStreamQueryHandler, rewriteRequestCondition: RewriteRequestCondition, exceptionHandler: RequestExceptionHandler): QueryRouteModule

rewriteRequestCondition

@Bean

@ConditionalOnMissingBean

fun rewriteRequestCondition(): RewriteRequestCondition

routeHandlerFunctionRegistrar

@Bean

fun routeHandlerFunctionRegistrar(routeModules: ObjectProvider<WebFluxRouteModule>, httpFactories: ObjectProvider<HttpRouteHandlerFunctionFactory>): RouteHandlerFunctionRegistrar

snapshotRouteModule

@Bean

@Order(value = -2147483648)

@ConditionalOnMissingBean

fun snapshotRouteModule(stateAggregateFactory: StateAggregateFactory, eventStore: EventStore, snapshotRepository: SnapshotRepository, exceptionHandler: RequestExceptionHandler, batchExecutionPolicy: BatchExecutionPolicy): SnapshotRouteModule

stateRouteModule

@Bean

@Order(value = -2147483648)

@ConditionalOnMissingBean

fun stateRouteModule(stateAggregateRepository: StateAggregateRepository, stateAggregateFactory: StateAggregateFactory, eventStore: EventStore, exceptionHandler: RequestExceptionHandler, tracingPolicy: TracingPolicy): StateRouteModule

tracingPolicy

@Bean

@ConditionalOnMissingBean

fun tracingPolicy(): TracingPolicy

webFluxErrorStrategy

@Bean

@ConditionalOnMissingBean

fun webFluxErrorStrategy(): WebFluxErrorStrategy