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

Package-level declarations

Types

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

CommandBuilderExtractor

fun interface CommandBuilderExtractor

CommandFacadeBodyExtractor

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

Reads the global command facade's request: the Command-Type header names the command, the optional Command-Aggregate-Context / Command-Aggregate-Name headers name its aggregate, and the body is the command.

CommandMessageExtractor

interface CommandMessageExtractor

DefaultCommandBuilderExtractor

object DefaultCommandBuilderExtractor : CommandBuilderExtractor

Builds a command from its route's request. Each identity fact comes from where the route's RouteIdentityBinding says (path variable, static tenant, header), decided by IdentityResolver; the space (Wow-Space-Id, then any space header alias) is taken only for a spaced aggregate, so any other aggregate's command carries the default space whatever the request sends.

DefaultCommandMessageExtractor

class DefaultCommandMessageExtractor(commandMessageFactory: CommandMessageFactory, commandBuilderExtractor: CommandBuilderExtractor, commandRequestHeaderAppends: List<CommandRequestHeaderAppender> = listOf(), identityHeaderAliases: IdentityHeaderAliases = IdentityHeaderAliases.NONE) : CommandMessageExtractor