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

EventStreamExchange

interface EventStreamExchange : EventExchange<EventStreamExchange, DomainEventStream>

Exchange interface for domain event stream processing.

This interface extends MessageExchange to provide event stream specific functionality for handling collections of domain events within the messaging system.

Inheritors

SimpleEventStreamExchange

Properties

attributes

abstract val attributes: MutableMap<String, Any>

message

abstract val message: DomainEventStream

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

EventStreamExchange

See also

Inheritors

Properties

Functions