wow-core/me.ahoo.wow.command/ServerCommandExchange

ServerCommandExchange

interface ServerCommandExchange<C : Any> : CommandExchange<ServerCommandExchange<C>, C>

Server-side command exchange interface for commands being processed by the server.

This interface provides access to command processing context, including the aggregate processor, command results, event streams, and error information. It allows processors to store and retrieve data throughout the command handling pipeline.

Parameters

the type of the command

Inheritors

SimpleServerCommandExchange

Properties

attributes

abstract val attributes: MutableMap<String, Any>

message

abstract val message: CommandMessage<C>

Functions

acknowledge

open fun acknowledge(): Mono<Void>

clearError

open override fun clearError()

Clears the current error object.

extractDeclared

open override fun <T : Any> extractDeclared(type: Class<T>): T?

Extracts an object of the specified type from the exchange context.

extractObject

open fun <T : Any> extractObject(type: KType): T?

getAggregateProcessor

open fun getAggregateProcessor(): AggregateProcessor<C>?

Gets the aggregate processor responsible for handling this command.

getAggregateVersion

open override fun getAggregateVersion(): Int?

getAttribute

open fun <T> getAttribute(key: String): T?

getCommandAggregate

fun <C : Any, S : Any> ServerCommandExchange<*>.getCommandAggregate(): CommandAggregate<C, S>?

getCommandInvokeResult

open fun <R> getCommandInvokeResult(): R?

Gets the result of invoking the command on the aggregate.

getCommandResult

open override fun getCommandResult(): Map<String, Any>

open override fun <R> getCommandResult(key: String): R?

getError

open override fun getError(): Throwable?

Gets the error that occurred during command processing.

getEventStream

open fun getEventStream(): DomainEventStream?

Gets the event stream generated by the command execution.

getFunction

open fun getFunction(): FunctionInfo?

getFunctionAs

open fun <FUN : FunctionInfo> getFunctionAs(): FUN?

getServiceProvider

open fun getServiceProvider(): ServiceProvider?

removeAttribute

open fun removeAttribute(key: String): ServerCommandExchange<C>

setAggregateProcessor

open fun setAggregateProcessor(aggregateProcessor: AggregateProcessor<*>): ServerCommandExchange<C>

Sets the aggregate processor responsible for handling this command.

setAggregateVersion

open fun setAggregateVersion(aggregateVersion: Int): ServerCommandExchange<C>

Sets the version of the aggregate after command processing.

setAttribute

open fun setAttribute(key: String, value: Any): ServerCommandExchange<C>

setCommandAggregate

fun ServerCommandExchange<*>.setCommandAggregate(commandAggregate: CommandAggregate<*, *>): ServerCommandExchange<*>

setCommandInvokeResult

open fun setCommandInvokeResult(result: Any): ServerCommandExchange<C>

Sets the result of invoking the command on the aggregate.

setCommandResult

open override fun setCommandResult(key: String, value: Any)

setError

open override fun setError(throwable: Throwable)

Sets the error object for this context.

setEventStream

open fun setEventStream(eventStream: DomainEventStream): ServerCommandExchange<C>

Sets the event stream generated by the command execution.

setFunction

open fun setFunction(functionInfo: FunctionInfo): ServerCommandExchange<C>

setServiceProvider

open fun setServiceProvider(serviceProvider: ServiceProvider): ServerCommandExchange<C>

ServerCommandExchange

Parameters

See also

Inheritors

Properties

Functions