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

SimpleClientCommandExchange

class SimpleClientCommandExchange<C : Any>(val message: CommandMessage<C>, val waitStrategy: WaitStrategy, val attributes: MutableMap<String, Any> = ConcurrentHashMap()) : ClientCommandExchange<C>

Simple implementation of ClientCommandExchange.

This class provides a basic implementation of the client command exchange, storing the command message, wait strategy, and any additional attributes.

Parameters

the type of the command

message

the command message being processed

waitStrategy

the strategy for waiting on command results

attributes

mutable map for storing additional exchange data

Constructors

SimpleClientCommandExchange

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

Properties

attributes

open override val attributes: MutableMap<String, Any>

message

open override val message: CommandMessage<C>

waitStrategy

open override val waitStrategy: WaitStrategy

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): ClientCommandExchange<C>

setAttribute

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

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): ClientCommandExchange<C>

setServiceProvider

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

SimpleClientCommandExchange

Parameters

See also

Constructors

Properties

Functions