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

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.

This data class provides a concrete implementation of the DomainEvent interface, representing a domain event with all required metadata and payload information.

Parameters

T

The type of the event body

See also

Constructors

SimpleDomainEvent

constructor(id: String = generateGlobalId(), header: Header = DefaultHeader.empty(), body: T, aggregateId: AggregateId, ownerId: String = OwnerId.DEFAULT_OWNER_ID, version: Int, sequence: Int = DEFAULT_EVENT_SEQUENCE, revision: String = DEFAULT_REVISION, commandId: String, name: String = body.javaClass.toName(), isLast: Boolean = true, createTime: Long = System.currentTimeMillis())

Creates a new SimpleDomainEvent with the specified properties

Properties

open override val aggregateId: AggregateId

The aggregate ID this event belongs to

open override val aggregateName: String

open override val body: T

The event payload data

open override val commandId: String

The ID of the command that triggered this event

open override val contextName: String

open override val createTime: Long

The timestamp when the event was created (default: current time)

open override val header: Header

The message header containing metadata (default: empty header)

open override val id: String

The unique identifier of this event (default: generated global ID)

open val initialized: Boolean

isInitialVersion

open val isInitialVersion: Boolean

open override val isLast: Boolean

Whether this is the last event in the stream (default: true)

open val isReadOnly: Boolean

open override val name: String

The event name (default: derived from body class name)

open override val ownerId: String

The owner identifier (default: DEFAULT_OWNER_ID)

open override val revision: String

The event schema revision (default: DEFAULT_REVISION)

open override val sequence: Int

The sequence number within the event stream (default: DEFAULT_EVENT_SEQUENCE)

open override val version: Int

The aggregate version when this event was created

Functions

fun NamedAggregate.aggregateId(id: String = generateId(), tenantId: String = TenantId.DEFAULT_TENANT_ID): DefaultAggregateId

Creates an AggregateId for this NamedAggregate with the specified parameters.

fun <T> NamedAggregate.aggregateType(): Class<T>?

Finds the aggregate type class associated with this named aggregate.

asAggregateMetadata

fun <C : Any, S : Any> NamedAggregate.asAggregateMetadata(): AggregateMetadata<C, S>

Converts this NamedAggregate to its corresponding AggregateMetadata.

fun NamedAggregate.generateId(): String

Generates a unique ID string for this NamedAggregate.

getContextAlias

fun NamedBoundedContext.getContextAlias(boundedContext: BoundedContext? = MetadataSearcher.metadata.contexts[contextName]): String

getContextAliasPrefix

fun NamedBoundedContext.getContextAliasPrefix(): String

Gets the context alias prefix for this bounded context.

fun NamedAggregate.isLocal(): Boolean

Checks if the named aggregate is available locally at runtime.

isSameAggregateName

open override fun isSameAggregateName(other: NamedAggregate): Boolean

isSameBoundedContext

open override fun isSameBoundedContext(other: NamedBoundedContext): Boolean

fun Message<*, *>.match(function: FunctionInfo): Boolean

Checks if this message matches the given function for compensation purposes.

fun NamedAggregate.materialize(): MaterializedNamedAggregate

Materializes this NamedAggregate into a MaterializedNamedAggregate.

requiredAggregateType

fun <T> NamedAggregate.requiredAggregateType(): Class<T>

Finds the aggregate type class associated with this named aggregate, throwing an exception if not found.

toEventNamedAggregate

fun NamedAggregate.toEventNamedAggregate(eventName: String): EventNamedAggregate

Extension function to convert a NamedAggregate to an EventNamedAggregate.

fun DomainEvent<out ErrorInfo>.toException(): DomainEventException

Extension function to convert a domain event with error info to a DomainEventException.

fun AggregateIdCapable.toGroupKey(parallelism: Int = DEFAULT_PARALLELISM): Int

Computes a grouping key for parallel processing based on the aggregate ID.

toNamedAggregateString

fun NamedAggregate.toNamedAggregateString(): String

Converts this NamedAggregate to its string representation.

toStringWithAlias

fun NamedAggregate.toStringWithAlias(): String

Converts this NamedAggregate to a string representation using the context alias.

open fun withHeader(additionalSource: Map<String, String>): DomainEvent<T>

open fun withHeader(key: String, value: String): DomainEvent<T>

open fun withReadOnly(): DomainEvent<T>