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

SimpleServerCommandExchange

class SimpleServerCommandExchange<C : Any>(val message: CommandMessage<C>, val attributes: MutableMap<String, Any> = ConcurrentHashMap()) : ServerCommandExchange<C>

Simple implementation of ServerCommandExchange.

This class provides a basic implementation of the server command exchange, storing the command message and any additional attributes for command processing.

Parameters

the type of the command

message

the command message being processed

attributes

mutable map for storing additional exchange data

Constructors

SimpleServerCommandExchange

constructor(message: CommandMessage<C>, attributes: MutableMap<String, Any> = ConcurrentHashMap())

Properties

attributes

open override val attributes: MutableMap<String, Any>

message

open override 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>

SimpleServerCommandExchange

Parameters

See also

Constructors

Properties

Functions