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

Link copied to clipboard
constructor()

Types

Link copied to clipboard
object Companion

Functions

Link copied to clipboard
@Bean
@Order(value = -2147483648)
@ConditionalOnMissingBean(name = ["aggregateTracingHandlerFunctionFactory"])
fun aggregateTracingHandlerFunctionFactory(stateAggregateFactory: StateAggregateFactory, eventStore: EventStore, exceptionHandler: RequestExceptionHandler): AggregateTracingHandlerFunctionFactory
@Bean
@Order(value = -2147483648)
@ConditionalOnMissingBean(name = ["batchRegenerateSnapshotHandlerFunctionFactory"])
fun batchRegenerateSnapshotHandlerFunctionFactory(stateAggregateFactory: StateAggregateFactory, eventStore: EventStore, snapshotRepository: SnapshotRepository, exceptionHandler: RequestExceptionHandler): BatchRegenerateSnapshotHandlerFunctionFactory
Link copied to clipboard
@Bean
@Order(value = -2147483648)
@ConditionalOnMissingBean(name = ["commandFacadeHandlerFunctionFactory"])
fun commandFacadeHandlerFunctionFactory(commandGateway: CommandGateway, commandMessageParser: CommandMessageParser, exceptionHandler: RequestExceptionHandler): CommandFacadeHandlerFunctionFactory
Link copied to clipboard
@Bean
@Order(value = -2147483648)
@ConditionalOnMissingBean(name = ["commandHandlerFunctionFactory"])
fun commandHandlerFunctionFactory(commandGateway: CommandGateway, commandMessageParser: CommandMessageParser, exceptionHandler: RequestExceptionHandler): CommandHandlerFunctionFactory
Link copied to clipboard
@Bean
@ConditionalOnMissingBean
fun commandMessageParser(commandMessageFactory: CommandMessageFactory, commandRequestHeaderAppenderObjectProvider: ObjectProvider<CommandRequestHeaderAppender>): CommandMessageParser
Link copied to clipboard
Link copied to clipboard
@Bean
@ConditionalOnProperty(value = ["wow.webflux.command.request.appender.ip.enabled"], matchIfMissing = true, havingValue = "true")
fun commandRequestRemoteIpHeaderAppender(): CommandRequestRemoteIpHeaderAppender
Link copied to clipboard
@Bean
@ConditionalOnProperty(value = ["wow.webflux.command.request.appender.agent.enabled"], matchIfMissing = true, havingValue = "true")
fun commandRequestUserAgentHeaderAppender(): CommandRequestUserAgentHeaderAppender
Link copied to clipboard
@Bean
fun commandRouterFunction(routerSpecs: RouterSpecs, routeHandlerFunctionRegistrar: RouteHandlerFunctionRegistrar): RouterFunction<ServerResponse>
Link copied to clipboard
@Bean
@Order(value = -2147483648)
@ConditionalOnMissingBean(name = ["commandWaitHandlerFunctionFactory"])
fun commandWaitHandlerFunctionFactory(waitStrategyRegistrar: WaitStrategyRegistrar): CommandWaitHandlerFunctionFactory
Link copied to clipboard
@Bean
@Order(value = -2147483648)
@ConditionalOnMissingBean(name = ["countEventStreamHandlerFunctionFactory"])
fun countEventStreamHandlerFunctionFactory(queryHandler: EventStreamQueryHandler, exceptionHandler: RequestExceptionHandler): CountEventStreamHandlerFunctionFactory
Link copied to clipboard
@Bean
@Order(value = -2147483648)
@ConditionalOnMissingBean(name = ["countSnapshotHandlerFunctionFactory"])
fun countSnapshotHandlerFunctionFactory(snapshotQueryHandler: SnapshotQueryHandler, exceptionHandler: RequestExceptionHandler): CountSnapshotHandlerFunctionFactory
Link copied to clipboard
@Bean
@Order(value = -2147483648)
@ConditionalOnMissingBean(name = ["eventCompensateHandlerFunctionFactory"])
fun eventCompensateHandlerFunctionFactory(eventCompensateSupporter: EventCompensateSupporter, exceptionHandler: RequestExceptionHandler): EventCompensateHandlerFunctionFactory
Link copied to clipboard
@Bean
@ConditionalOnMissingBean
fun exceptionHandler(): RequestExceptionHandler
Link copied to clipboard
@Bean
@Order(value = -2147483648)
@ConditionalOnMissingBean(name = ["generateBIScriptHandlerFunctionFactory"])
fun generateBIScriptHandlerFunctionFactory(@Nullable kafkaProperties: KafkaProperties?): GenerateBIScriptHandlerFunctionFactory
Link copied to clipboard
@Bean
@Order(value = -2147483648)
@ConditionalOnMissingBean(name = ["getWowMetadataHandlerFunctionFactory"])
fun getWowMetadataHandlerFunctionFactory(): GetWowMetadataHandlerFunctionFactory
Link copied to clipboard
@Bean
fun globalExceptionHandler(): WebExceptionHandler
Link copied to clipboard
@Bean
@Order(value = -2147483648)
@ConditionalOnMissingBean(name = ["globalIdHandlerFunctionFactory"])
fun globalIdHandlerFunctionFactory(): GlobalIdHandlerFunctionFactory
Link copied to clipboard
@Bean
@Order(value = -2147483648)
@ConditionalOnMissingBean(name = ["idsQueryAggregateHandlerFunctionFactory"])
fun idsQueryAggregateHandlerFunctionFactory(stateAggregateRepository: StateAggregateRepository, exceptionHandler: RequestExceptionHandler): IdsQueryAggregateHandlerFunctionFactory
@Bean
@Order(value = -2147483648)
@ConditionalOnMissingBean(name = ["listQueryEventStreamHandlerFunctionFactory"])
fun listQueryEventStreamHandlerFunctionFactory(eventStreamQueryHandler: EventStreamQueryHandler, exceptionHandler: RequestExceptionHandler): ListQueryEventStreamHandlerFunctionFactory
Link copied to clipboard
@Bean
@Order(value = -2147483648)
@ConditionalOnMissingBean(name = ["listQuerySnapshotHandlerFunctionFactory"])
fun listQuerySnapshotHandlerFunctionFactory(snapshotQueryHandler: SnapshotQueryHandler, exceptionHandler: RequestExceptionHandler): ListQuerySnapshotHandlerFunctionFactory
@Bean
@Order(value = -2147483648)
@ConditionalOnMissingBean(name = ["listQuerySnapshotStateHandlerFunctionFactory"])
fun listQuerySnapshotStateHandlerFunctionFactory(snapshotQueryHandler: SnapshotQueryHandler, exceptionHandler: RequestExceptionHandler): ListQuerySnapshotStateHandlerFunctionFactory
Link copied to clipboard
@Bean
@Order(value = -2147483648)
@ConditionalOnMissingBean(name = ["loadAggregateHandlerFunctionFactory"])
fun loadAggregateHandlerFunctionFactory(stateAggregateRepository: StateAggregateRepository, exceptionHandler: RequestExceptionHandler): LoadAggregateHandlerFunctionFactory
Link copied to clipboard
@Bean
@Order(value = -2147483648)
@ConditionalOnMissingBean(name = ["loadEventStreamHandlerFunctionFactory"])
fun loadEventStreamHandlerFunctionFactory(eventStreamQueryHandler: EventStreamQueryHandler, exceptionHandler: RequestExceptionHandler): LoadEventStreamHandlerFunctionFactory
Link copied to clipboard
@Bean
@Order(value = -2147483648)
@ConditionalOnMissingBean(name = ["loadSnapshotHandlerFunctionFactory"])
fun loadSnapshotHandlerFunctionFactory(snapshotQueryHandler: SnapshotQueryHandler, exceptionHandler: RequestExceptionHandler): LoadSnapshotHandlerFunctionFactory
@Bean
@Order(value = -2147483648)
@ConditionalOnMissingBean(name = ["loadTimeBasedAggregateHandlerFunctionFactory"])
fun loadTimeBasedAggregateHandlerFunctionFactory(stateAggregateRepository: StateAggregateRepository, exceptionHandler: RequestExceptionHandler): LoadTimeBasedAggregateHandlerFunctionFactory
@Bean
@Order(value = -2147483648)
@ConditionalOnMissingBean(name = ["loadVersionedAggregateHandlerFunctionFactory"])
fun loadVersionedAggregateHandlerFunctionFactory(stateAggregateRepository: StateAggregateRepository, exceptionHandler: RequestExceptionHandler): LoadVersionedAggregateHandlerFunctionFactory
@Bean
@Order(value = -2147483648)
@ConditionalOnMissingBean(name = ["pagedQueryEventStreamHandlerFunctionFactory"])
fun pagedQueryEventStreamHandlerFunctionFactory(eventStreamQueryHandler: EventStreamQueryHandler, exceptionHandler: RequestExceptionHandler): PagedQueryEventStreamHandlerFunctionFactory
Link copied to clipboard
@Bean
@Order(value = -2147483648)
@ConditionalOnMissingBean(name = ["pagedQuerySnapshotHandlerFunctionFactory"])
fun pagedQuerySnapshotHandlerFunctionFactory(snapshotQueryHandler: SnapshotQueryHandler, exceptionHandler: RequestExceptionHandler): PagedQuerySnapshotHandlerFunctionFactory
@Bean
@Order(value = -2147483648)
@ConditionalOnMissingBean(name = ["pagedQuerySnapshotStateHandlerFunctionFactory"])
fun pagedQuerySnapshotStateHandlerFunctionFactory(snapshotQueryHandler: SnapshotQueryHandler, exceptionHandler: RequestExceptionHandler): PagedQuerySnapshotStateHandlerFunctionFactory
Link copied to clipboard
@Bean
@Order(value = -2147483648)
@ConditionalOnMissingBean(name = ["regenerateSnapshotHandlerFunctionFactory"])
fun regenerateSnapshotHandlerFunctionFactory(stateAggregateFactory: StateAggregateFactory, eventStore: EventStore, snapshotRepository: SnapshotRepository, exceptionHandler: RequestExceptionHandler): RegenerateSnapshotHandlerFunctionFactory
Link copied to clipboard
@Bean
@Order(value = -2147483648)
@ConditionalOnMissingBean(name = ["resendStateEventFunctionFactory"])
fun resendStateEventFunctionFactory(snapshotRepository: SnapshotRepository, stateEventCompensator: StateEventCompensator, exceptionHandler: RequestExceptionHandler): ResendStateEventFunctionFactory
Link copied to clipboard
Link copied to clipboard
@Bean
@Order(value = -2147483648)
@ConditionalOnMissingBean(name = ["singleSnapshotHandlerFunctionFactory"])
fun singleSnapshotHandlerFunctionFactory(snapshotQueryHandler: SnapshotQueryHandler, exceptionHandler: RequestExceptionHandler): SingleSnapshotHandlerFunctionFactory
@Bean
@Order(value = -2147483648)
@ConditionalOnMissingBean(name = ["singleSnapshotStateHandlerFunctionFactory"])
fun singleSnapshotStateHandlerFunctionFactory(snapshotQueryHandler: SnapshotQueryHandler, exceptionHandler: RequestExceptionHandler): SingleSnapshotStateHandlerFunctionFactory