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

SimpleEventStreamExchange

class SimpleEventStreamExchange(val message: DomainEventStream, val attributes: MutableMap<String, Any> = ConcurrentHashMap()) : EventStreamExchange

Simple implementation of EventStreamExchange.

This class provides a basic implementation of the EventStreamExchange interface, storing the domain event stream message and managing exchange attributes.

Constructors

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

Creates a new SimpleEventStreamExchange with the given message and attributes

Properties

attributes

open override val attributes: MutableMap<String, Any>

Mutable map for storing exchange attributes (default: empty ConcurrentHashMap)

message

open override val message: DomainEventStream

The domain event stream being processed

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

setAttribute

open fun setAttribute(key: String, value: Any): EventStreamExchange

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

setServiceProvider

open fun setServiceProvider(serviceProvider: ServiceProvider): EventStreamExchange

SimpleEventStreamExchange

See also

Constructors

Properties

Functions