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

CommandExchange

interface CommandExchange<SOURCE : CommandExchange<SOURCE, C>, C : Any> : MessageExchange<SOURCE, CommandMessage<C>>

Base interface for command exchanges that facilitate message passing during command processing.

Command exchanges provide a context for command handling, allowing processors to access and modify command-related data throughout the processing pipeline.

Author

ahoo wang

Parameters

SOURCE

the type of the command exchange source

the type of the command

Inheritors

ClientCommandExchange

ServerCommandExchange

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 fun <T : Any> extractDeclared(type: Class<T>): T?

extractObject

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

getAggregateVersion

open fun getAggregateVersion(): Int?

getAttribute

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

getCommandResult

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

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

getError

open override fun getError(): Throwable?

Gets the current error object.

getFunction

open fun getFunction(): FunctionInfo?

getFunctionAs

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

getServiceProvider

open fun getServiceProvider(): ServiceProvider?

removeAttribute

open fun removeAttribute(key: String): SOURCE

setAttribute

open fun setAttribute(key: String, value: Any): SOURCE

setCommandResult

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

setError

open override fun setError(throwable: Throwable)

Sets the error object for this context.

setFunction

open fun setFunction(functionInfo: FunctionInfo): SOURCE

setServiceProvider

open fun setServiceProvider(serviceProvider: ServiceProvider): SOURCE