wow-webflux/me.ahoo.wow.webflux.route.command

Package-level declarations

Types

Link copied to clipboard
class CommandFacadeHandlerFunction(commandGateway: CommandGateway, commandMessageExtractor: CommandMessageExtractor, exceptionHandler: RequestExceptionHandler, timeout: Duration = DEFAULT_TIME_OUT) : HandlerFunction<ServerResponse>

org.springframework.web.reactive.result.method.annotation.RequestMappingHandlerMapping

Link copied to clipboard
class CommandFacadeHandlerFunctionFactory(commandGateway: CommandGateway, commandMessageExtractor: CommandMessageExtractor, exceptionHandler: RequestExceptionHandler, timeout: Duration = DEFAULT_TIME_OUT) : RouteHandlerFunctionFactory<CommandFacadeRouteSpec>
Link copied to clipboard
class CommandHandler(commandGateway: CommandGateway, commandMessageExtractor: CommandMessageExtractor, timeout: Duration = DEFAULT_TIME_OUT)
Link copied to clipboard
class CommandHandlerFunction(aggregateRouteMetadata: AggregateRouteMetadata<*>, commandRouteMetadata: CommandRouteMetadata<out Any>, commandGateway: CommandGateway, commandMessageExtractor: CommandMessageExtractor, exceptionHandler: RequestExceptionHandler, timeout: Duration = DEFAULT_TIME_OUT) : HandlerFunction<ServerResponse>

org.springframework.web.reactive.result.method.annotation.RequestMappingHandlerMapping

Link copied to clipboard
class CommandHandlerFunctionFactory(commandGateway: CommandGateway, commandMessageExtractor: CommandMessageExtractor, exceptionHandler: RequestExceptionHandler, timeout: Duration = DEFAULT_TIME_OUT) : RouteHandlerFunctionFactory<CommandRouteSpec>

Properties

Link copied to clipboard

Functions

Link copied to clipboard
fun ServerRequest.extractWaitStrategy(commandMessage: CommandMessage<Any>): WaitStrategy
Link copied to clipboard
fun ServerRequest.getAggregateId(): String?
fun ServerRequest.getAggregateId(owner: AggregateRoute.Owner): String?
fun ServerRequest.getAggregateId(owner: AggregateRoute.Owner, ownerId: String?): String?
Link copied to clipboard
fun ServerRequest.getLocalFirst(): Boolean?
Link copied to clipboard
fun ServerRequest.getOwnerId(): String?
Link copied to clipboard
fun ServerRequest.getTenantId(aggregateMetadata: AggregateMetadata<*, *>): String?
Link copied to clipboard
fun ServerRequest.getTenantIdOrDefault(aggregateMetadata: AggregateMetadata<*, *>): String
Link copied to clipboard
fun ServerRequest.getWaitContext(): String
Link copied to clipboard
fun ServerRequest.getWaitFunction(): String
Link copied to clipboard
fun ServerRequest.getWaitProcessor(): String
Link copied to clipboard
fun ServerRequest.getWaitStage(): CommandStage
Link copied to clipboard
fun ServerRequest.getWaitTailContext(): String
Link copied to clipboard
fun ServerRequest.getWaitTailFunction(): String
Link copied to clipboard
fun ServerRequest.getWaitTailProcessor(): String
Link copied to clipboard
fun ServerRequest.getWaitTailStage(): CommandStage?
Link copied to clipboard
fun ServerRequest.getWaitTimeout(default: Duration = DEFAULT_TIME_OUT): Duration
Link copied to clipboard
fun ServerRequest.isSse(): Boolean
Link copied to clipboard
fun Flux<CommandResult>.toCommandResponse(request: ServerRequest, exceptionHandler: RequestExceptionHandler): Mono<ServerResponse>