wow-core/me.ahoo.wow.eventsourcing.state/SimpleStateEventExchange

SimpleStateEventExchange

class SimpleStateEventExchange<S : Any>(val message: StateEvent<S>, val attributes: MutableMap<String, Any> = ConcurrentHashMap()) : StateEventExchange<S>

Simple implementation of StateEventExchange using a concurrent hash map for attributes. Provides thread-safe attribute storage for message processing.

Parameters

The type of the state in the state event.

message

The state event message being processed.

attributes

Mutable map for storing processing attributes (default: empty ConcurrentHashMap).

Constructors

SimpleStateEventExchange

constructor(message: StateEvent<S>, attributes: MutableMap<String, Any> = ConcurrentHashMap())

Properties

attributes

open override val attributes: MutableMap<String, Any>

message

open override val message: StateEvent<S>

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): StateEventExchange<S>

setAttribute

open fun setAttribute(key: String, value: Any): StateEventExchange<S>

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): StateEventExchange<S>

setServiceProvider

open fun setServiceProvider(serviceProvider: ServiceProvider): StateEventExchange<S>