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

Package-level declarations

Types

class CommandFacadeHandlerFunction(commandGateway: CommandGateway, commandMessageExtractor: CommandMessageExtractor, exceptionHandler: RequestExceptionHandler, commandWaitPolicy: CommandWaitPolicy) : HandlerFunction<ServerResponse>

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

CommandFacadeHandlerFunctionFactory

class CommandFacadeHandlerFunctionFactory(commandGateway: CommandGateway, commandMessageExtractor: CommandMessageExtractor, exceptionHandler: RequestExceptionHandler, commandWaitPolicy: CommandWaitPolicy) : NoMetadataRouteHandlerFunctionFactorySupport

CommandHandler

class CommandHandler(commandGateway: CommandGateway, commandMessageExtractor: CommandMessageExtractor, commandWaitPolicy: CommandWaitPolicy)

CommandHandlerFunction

class CommandHandlerFunction(aggregateRouteMetadata: AggregateRouteMetadata<*>, commandRouteMetadata: CommandRouteMetadata<out Any>, commandGateway: CommandGateway, commandMessageExtractor: CommandMessageExtractor, exceptionHandler: RequestExceptionHandler, commandWaitPolicy: CommandWaitPolicy) : HandlerFunction<ServerResponse>

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

CommandHandlerFunctionFactory

class CommandHandlerFunctionFactory(commandGateway: CommandGateway, commandMessageExtractor: CommandMessageExtractor, exceptionHandler: RequestExceptionHandler, commandWaitPolicy: CommandWaitPolicy) : CommandRouteHandlerFunctionFactorySupport

Properties

DEFAULT_TIME_OUT

val DEFAULT_TIME_OUT: Duration

Functions

extractWaitPlan

fun ServerRequest.extractWaitPlan(commandMessage: CommandMessage<Any>): WaitPlan

getAggregateId

fun ServerRequest.getAggregateId(): String?

fun ServerRequest.getAggregateId(owner: AggregateRoute.Owner): String?

fun ServerRequest.getAggregateId(owner: AggregateRoute.Owner, ownerId: String?): String?

getLocalFirst

fun ServerRequest.getLocalFirst(): Boolean?

getOwnerId

fun ServerRequest.getOwnerId(): String?

getSpaceId

fun ServerRequest.getSpaceId(): SpaceId?

fun ServerRequest.getSpaceId(aggregateRouteMetadata: AggregateRouteMetadata<*>): SpaceId?

The space this request states for the aggregate of aggregateRouteMetadata: the Wow-Space-Id header when the aggregate is spaced, otherwise null whatever the request sends.

getTenantId

fun ServerRequest.getTenantId(aggregateMetadata: AggregateMetadata<*, *>): String?

getTenantIdOrDefault

fun ServerRequest.getTenantIdOrDefault(aggregateMetadata: AggregateMetadata<*, *>): String

getWaitContext

fun ServerRequest.getWaitContext(): String

getWaitFunction

fun ServerRequest.getWaitFunction(): String

getWaitProcessor

fun ServerRequest.getWaitProcessor(): String

getWaitStage

fun ServerRequest.getWaitStage(): CommandStage

getWaitTailContext

fun ServerRequest.getWaitTailContext(): String

getWaitTailFunction

fun ServerRequest.getWaitTailFunction(): String

getWaitTailProcessor

fun ServerRequest.getWaitTailProcessor(): String

getWaitTailStage

fun ServerRequest.getWaitTailStage(): CommandStage?

getWaitTimeout

fun ServerRequest.getWaitTimeout(default: Duration = DEFAULT_TIME_OUT): Duration

isSse

fun ServerRequest.isSse(): Boolean

toCommandResponse

fun Flux<CommandResult>.toCommandResponse(request: ServerRequest, exceptionHandler: RequestExceptionHandler): Mono<ServerResponse>