Package-level declarations

Types

Link copied to clipboard
class CommandBodyExtractor<C : Any>(commandRouteMetadata: CommandRouteMetadata<C>) : BodyExtractor<Mono<C>, ReactiveHttpInputMessage>
Link copied to clipboard
object CommandFacadeBodyExtractor : BodyExtractor<Mono<Tuple2<Any, AggregateMetadata<Any, Any>>>, ReactiveHttpInputMessage>
Link copied to clipboard
class CommandFacadeHandlerFunction(commandGateway: CommandGateway, commandMessageFactory: CommandMessageFactory, 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, commandMessageFactory: CommandMessageFactory, exceptionHandler: RequestExceptionHandler, timeout: Duration = DEFAULT_TIME_OUT) : RouteHandlerFunctionFactory<CommandFacadeRouteSpec>
Link copied to clipboard
class CommandHandler(commandGateway: CommandGateway, commandMessageFactory: CommandMessageFactory, timeout: Duration = DEFAULT_TIME_OUT)
Link copied to clipboard
class CommandHandlerFunction(aggregateMetadata: AggregateMetadata<*, *>, commandRouteMetadata: CommandRouteMetadata<out Any>, commandGateway: CommandGateway, commandMessageFactory: CommandMessageFactory, 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, commandMessageFactory: CommandMessageFactory, exceptionHandler: RequestExceptionHandler, timeout: Duration = DEFAULT_TIME_OUT) : RouteHandlerFunctionFactory<CommandRouteSpec>
Link copied to clipboard

Properties

Link copied to clipboard

Functions

Link copied to clipboard
fun ServerRequest.getCommandStage(): CommandStage
Link copied to clipboard
fun ServerRequest.getWaitContext(): String
Link copied to clipboard
fun ServerRequest.getWaitProcessor(): String
Link copied to clipboard
fun ServerRequest.getWaitTimeout(default: Duration = DEFAULT_TIME_OUT): Duration