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.

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

confirmLocalDelivery

fun MessageExchange<*, *>.confirmLocalDelivery()

Confirms that this receiver synchronously admitted the local exchange.

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?

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