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

DomainEventExchange

interface DomainEventExchange<T : Any> : EventExchange<DomainEventExchange<T>, DomainEvent<T>>

Exchange interface for domain event processing.

This interface extends MessageExchange to provide domain event specific functionality for handling domain events within the messaging system. It provides access to event processing functions and manages the exchange lifecycle.

Type Parameters

The type of the domain event body

Inheritors

SimpleDomainEventExchange

StateDomainEventExchange

Properties

attributes

abstract val attributes: MutableMap<String, Any>

message

abstract val message: DomainEvent<T>

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?

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>

DomainEventExchange

Type Parameters

See also

Inheritors

Properties

Functions