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.

Type 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.

confirmLocalDelivery

fun MessageExchange<*, *>.confirmLocalDelivery()

Confirms that this receiver synchronously admitted the local exchange.

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?

getAggregateMetadata

open fun getAggregateMetadata(): AggregateMetadata<*, *>?

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?

rejectLocalDelivery

fun MessageExchange<*, *>.rejectLocalDelivery()

Rejects local-only suppression when this exchange is filtered or cannot be admitted. The distributed copy then remains eligible for processing.

removeAttribute

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

setAggregateMetadata

open fun setAggregateMetadata(aggregateMetadata: AggregateMetadata<*, *>): 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

Type Parameters

See also

Inheritors

Properties

Functions