class DomainEventDispatcher(val name: String, val parallelism: Int = MessageParallelism.DEFAULT_PARALLELISM, val domainEventBus: DomainEventBus, val stateEventBus: StateEventBus, val functionRegistrar: DomainEventFunctionRegistrar, val eventHandler: DomainEventHandler, schedulerSupplier: AggregateSchedulerSupplier = DefaultAggregateSchedulerSupplier("EventDispatcher")) : AbstractEventDispatcher<Mono<*>>

Domain Event Dispatcher responsible for coordinating the processing of domain events.

DomainEventException

class DomainEventException(val domainEvent: DomainEvent<out ErrorInfo>) : WowException

Exception wrapper for domain events containing error information.

DomainEventExchange

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

Exchange interface for domain event processing.

DomainEventFunctionFilter

@Order(value = 0)

open class DomainEventFunctionFilter(serviceProvider: ServiceProvider) : ExchangeFilter<DomainEventExchange<*>>

Filter for processing domain events through registered event functions.

DomainEventFunctionRegistrar

class DomainEventFunctionRegistrar(actual: MessageFunctionRegistrar<MessageFunction<Any, DomainEventExchange<*>, Mono<*>>> = SimpleMessageFunctionRegistrar()) : AbstractEventFunctionRegistrar

Registrar for domain event processing functions.

DomainEventHandler

interface DomainEventHandler : EventHandler

Interface for domain event handlers.

DomainEventStream

interface DomainEventStream : EventMessage<DomainEventStream, List<DomainEvent<*>>> , RequestId, Iterable<DomainEvent<*>> , Copyable<DomainEventStream>

Domain Event Stream interface representing a sequence of domain events.

EventExchange

interface EventExchange<SOURCE : EventExchange<SOURCE, M>, M : EventMessage<*, *>> : MessageExchange<SOURCE, M>

EventHandler

interface EventHandler : Handler<DomainEventExchange<*>>

Base interface for event handlers that process domain event exchanges.

EventStreamExchange

interface EventStreamExchange : EventExchange<EventStreamExchange, DomainEventStream>

Exchange interface for domain event stream processing.

InMemoryDomainEventBus

class InMemoryDomainEventBus(val sinkSupplier: (NamedAggregate) -> Sinks.Many<DomainEventStream> = { Sinks.many().multicast().onBackpressureBuffer() }) : InMemoryMessageBus<DomainEventStream, EventStreamExchange> , LocalDomainEventBus

In-memory implementation of LocalDomainEventBus.

LocalDomainEventBus

interface LocalDomainEventBus : DomainEventBus, LocalMessageBus<DomainEventStream, EventStreamExchange>

Local Domain Event Bus interface for in-process event handling.

LocalFirstDomainEventBus

class LocalFirstDomainEventBus(val distributedBus: DistributedDomainEventBus, val localBus: LocalDomainEventBus = InMemoryDomainEventBus()) : DomainEventBus, LocalFirstMessageBus<DomainEventStream, EventStreamExchange>

Domain event bus that prioritizes local processing before distributed publishing.

NoOpDomainEventBus

object NoOpDomainEventBus : DomainEventBus

No-operation implementation of DomainEventBus.

SimpleDomainEvent

data class SimpleDomainEvent<T : Any>(val id: String = generateGlobalId(), val header: Header = DefaultHeader.empty(), val body: T, val aggregateId: AggregateId, val ownerId: String = OwnerId.DEFAULT_OWNER_ID, val version: Int, val sequence: Int = DEFAULT_EVENT_SEQUENCE, val revision: String = DEFAULT_REVISION, val commandId: String, val name: String = body.javaClass.toName(), val isLast: Boolean = true, val createTime: Long = System.currentTimeMillis()) : DomainEvent<T> , NamedAggregate

Simple implementation of DomainEvent.

SimpleDomainEventExchange

class SimpleDomainEventExchange<T : Any>(val message: DomainEvent<T>, val attributes: MutableMap<String, Any> = ConcurrentHashMap()) : DomainEventExchange<T>

Simple implementation of DomainEventExchange.

SimpleDomainEventStream

data class SimpleDomainEventStream(val id: String = generateGlobalId(), val requestId: String, val header: Header = DefaultHeader.empty(), val body: List<DomainEvent<*>>) : DomainEventStream, Iterable<DomainEvent<*>>

Simple implementation of DomainEventStream.

SimpleEventStreamExchange

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

Simple implementation of EventStreamExchange.

SimpleStateDomainEventExchange

class SimpleStateDomainEventExchange<S : Any, T : Any>(val state: ReadOnlyStateAggregate<S>, val message: DomainEvent<T>, val attributes: MutableMap<String, Any> = ConcurrentHashMap()) : StateDomainEventExchange<S, T>

Simple implementation of StateDomainEventExchange.

StateDomainEventExchange

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

Exchange interface for domain events with state context.

Functions

flatEvent

fun Any.flatEvent(): Iterable<Any>

Flattens an object into an iterable of events.

ignoreSourcing

fun DomainEventStream.ignoreSourcing(): Boolean

Determines if this event stream should be ignored during event sourcing.

toDomainEvent

fun <T : Any> T.toDomainEvent(aggregateId: AggregateId, commandId: String, id: String = generateGlobalId(), version: Int = Version.INITIAL_VERSION, ownerId: String = OwnerId.DEFAULT_OWNER_ID, sequence: Int = DEFAULT_EVENT_SEQUENCE, isLast: Boolean = true, header: Header = DefaultHeader.empty(), createTime: Long = System.currentTimeMillis()): DomainEvent<T>

Converts an object to a domain event with full parameter control.

fun <T : Any> T.toDomainEvent(aggregateId: String, tenantId: String, commandId: String, ownerId: String = OwnerId.DEFAULT_OWNER_ID, id: String = generateGlobalId(), version: Int = Version.INITIAL_VERSION, sequence: Int = DEFAULT_EVENT_SEQUENCE, isLast: Boolean = true, header: Header = DefaultHeader.empty(), createTime: Long = System.currentTimeMillis()): DomainEvent<T>

Converts an object to a domain event using string aggregate identifiers.

toDomainEventStream

fun Any.toDomainEventStream(upstream: CommandMessage<*>, aggregateVersion: Int, stateOwnerId: String = OwnerId.DEFAULT_OWNER_ID, header: Header = DefaultHeader.empty(), createTime: Long = System.currentTimeMillis()): DomainEventStream

Converts an object to a domain event stream based on a command message.