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<*>>

DomainEventException

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

DomainEventExchange

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

DomainEventFunctionFilter

@Order(value = 0)

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

DomainEventFunctionRegistrar

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

DomainEventHandler

interface DomainEventHandler : EventHandler

DomainEventStream

interface DomainEventStream : NamedBoundedContextMessage<DomainEventStream, List<DomainEvent<*>>> , RequestId, CommandId, NamedAggregate, Version, Iterable<DomainEvent<*>> , AggregateIdCapable, Copyable<DomainEventStream>

Event Stream . Relation: Event Stream 1:1 CommandId.

EventHandler

interface EventHandler : Handler<DomainEventExchange<*>>

EventStreamExchange

interface EventStreamExchange : MessageExchange<EventStreamExchange, DomainEventStream>

InMemoryDomainEventBus

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

LocalDomainEventBus

interface LocalDomainEventBus : DomainEventBus, LocalMessageBus<DomainEventStream, EventStreamExchange>

LocalFirstDomainEventBus

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

NoOpDomainEventBus

object NoOpDomainEventBus : DomainEventBus

SimpleDomainEvent

data class SimpleDomainEvent<T : Any>(val id: String = GlobalIdGenerator.generateAsString(), val header: Header = DefaultHeader.empty(), val body: T, val aggregateId: AggregateId, 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

SimpleDomainEventExchange

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

SimpleDomainEventStream

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

SimpleEventStreamExchange

class SimpleEventStreamExchange(val message: DomainEventStream, val attributes: MutableMap<String, Any> = ConcurrentHashMap()) : 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>

StateDomainEventExchange

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

Functions

ignoreSourcing

fun DomainEventStream.ignoreSourcing(): Boolean

toDomainEvent

fun <T : Any> T.toDomainEvent(aggregateId: AggregateId, commandId: String, 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>

fun <T : Any> T.toDomainEvent(aggregateId: String, tenantId: String, commandId: String, 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>

toDomainEventStream

fun Any.toDomainEventStream(upstream: CommandMessage<*>, aggregateVersion: Int, header: Header = DefaultHeader.empty()): DomainEventStream