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

Package-level declarations

Types

class CommandBodyExtractor<C : Any>(commandRouteMetadata: CommandRouteMetadata<C>) : BodyExtractor<Mono<C>, ReactiveHttpInputMessage>

object CommandFacadeBodyExtractor : BodyExtractor<Mono<Tuple2<Any, AggregateMetadata<Any, Any>>>, ReactiveHttpInputMessage>

class CommandFacadeHandlerFunction(commandGateway: CommandGateway, commandMessageParser: CommandMessageParser, exceptionHandler: RequestExceptionHandler, timeout: Duration = DEFAULT_TIME_OUT) : HandlerFunction<ServerResponse>

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

class CommandHandler(commandGateway: CommandGateway, commandMessageParser: CommandMessageParser, timeout: Duration = DEFAULT_TIME_OUT)

class CommandHandlerFunction(aggregateMetadata: AggregateMetadata<*, *>, commandRouteMetadata: CommandRouteMetadata<out Any>, commandGateway: CommandGateway, commandMessageParser: CommandMessageParser, exceptionHandler: RequestExceptionHandler, timeout: Duration = DEFAULT_TIME_OUT) : HandlerFunction<ServerResponse>

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

fun ServerRequest.getAggregateId(): String?

fun ServerRequest.getLocalFirst(): Boolean?

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

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

fun ServerRequest.getWaitContext(): String

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