wow-core/me.ahoo.wow.event/StateDomainEventExchange

StateDomainEventExchange

interface StateDomainEventExchange<S : Any, T : Any> : DomainEventExchange<T>

Exchange interface for domain events with state context.

This interface extends DomainEventExchange to provide access to the current state of an aggregate during event processing. It allows extracting state-related objects from the exchange context.

Type Parameters

The type of the aggregate state

The type of the domain event body

Inheritors

SimpleStateDomainEventExchange

Properties

attributes

abstract val attributes: MutableMap<String, Any>

message

abstract val message: DomainEvent<T>

state

abstract val state: ReadOnlyStateAggregate<S>

The read-only state aggregate containing current state information.

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

Extracts an object of the specified type from the exchange context.

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?

getCommandStream

fun DomainEventExchange<*>.getCommandStream(): CommandStream?

Retrieves the command stream from the domain event exchange attributes.

getError

open override fun getError(): Throwable?

Gets the current error object.

getEventFunction

open fun getEventFunction(): MessageFunction<Any, DomainEventExchange<*>, Mono<*>>?

Retrieves the event processing function for this exchange.

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

setAttribute

open fun setAttribute(key: String, value: Any): DomainEventExchange<T>

setCommandResult

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

setCommandStream

fun DomainEventExchange<*>.setCommandStream(commandStream: CommandStream): DomainEventExchange<*>

Sets the command stream in the domain event exchange attributes. This allows the command stream to be associated with the domain event for later retrieval.

setError

open override fun setError(throwable: Throwable)

Sets the error object for this context.

setFunction

open fun setFunction(functionInfo: FunctionInfo): DomainEventExchange<T>

setServiceProvider

open fun setServiceProvider(serviceProvider: ServiceProvider): DomainEventExchange<T>

StateDomainEventExchange

Type Parameters

See also

Inheritors

Properties

Functions