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 spaceId: SpaceId = SpaceIdCapable.DEFAULT_SPACE_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, spaceId: SpaceId = SpaceIdCapable.DEFAULT_SPACE_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, spaceId: SpaceId = SpaceIdCapable.DEFAULT_SPACE_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 = Version.UNINITIALIZED_VERSION, stateOwnerId: String = OwnerId.DEFAULT_OWNER_ID, stateSpaceId: String = SpaceIdCapable.DEFAULT_SPACE_ID, header: Header = DefaultHeader.empty(), createTime: Long = System.currentTimeMillis()): DomainEventStream

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