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

StateEventExchange

interface StateEventExchange<S : Any> : EventExchange<StateEventExchange<S>, StateEvent<S>>

Exchange container for state events during message processing. Provides access to the state event message and allows attaching processing attributes.

Parameters

The type of the state in the state event.

Inheritors

SimpleStateEventExchange

Properties

attributes

abstract val attributes: MutableMap<String, Any>

message

abstract 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>