5.21.2

wow-api/me.ahoo.wow.api.event/DomainEvent

DomainEvent

interface DomainEvent<T : Any> : NamedMessage<DomainEvent<T>, T> , AggregateIdCapable, OwnerId, CommandId, NamedAggregate, Version, Revision

DomainEvent .

Events published when a command is processed by the aggregate

由聚合发布的领域事件 .

领域事件推荐使用声明式（Declarative）设计的方式（幂等，类似于 Kubernetes apply、Docker 镜像层）即聚合根在事件朔源时只需要简单的将领域事件作为覆盖层（onSourcing 只对状态赋值，没有逻辑判断），事件朔源将可以不需要显式定义朔源函数。

Author

ahoo wang

Properties

abstract override val aggregateId: AggregateId

聚合ID，用于唯一标识一个聚合实例

abstract val aggregateName: String

abstract val body: T

The body of the message, containing the actual data payload of the message.

abstract val commandId: String

Represents a unique identifier for a command. This identifier is crucial for ensuring that each command can be uniquely identified, which is particularly useful in scenarios where idempotency of commands needs to be guaranteed or when tracking and correlating commands across system boundaries.

abstract val contextName: String

abstract override val createTime: Long

The create time of the message, represented as a Unix timestamp in milliseconds.

abstract val header: Header

The header of the message, containing metadata about the message.

abstract val id: String

Represents a unique identifier for the implementing entity.

open val initialized: Boolean

isInitialVersion

open val isInitialVersion: Boolean

open val isLast: Boolean

是否为事件流的最后一个事件

open val isReadOnly: Boolean

Indicates whether the message is read-only, based on the state of the header.

abstract val name: String

abstract val ownerId: String

资源拥有者的唯一标识符

open override val revision: String

Represents the revision of the domain event. This value is used to track changes or updates in the domain model, ensuring that each version of an aggregate can be uniquely identified and managed.

open val sequence: Int

abstract val version: Int

Functions

isSameAggregateName

open fun isSameAggregateName(other: NamedAggregate): Boolean

检查两个聚合根是否属于同一个上下文并具有相同的聚合根名称。

isSameBoundedContext

open fun isSameBoundedContext(other: NamedBoundedContext): Boolean

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

Adds all entries from the provided map to the message header and returns the message itself for method chaining.

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

Adds a key-value pair to the message header and returns the message itself for method chaining.

open fun withReadOnly(): DomainEvent<T>

Marks the message as read-only and returns the message itself for method chaining.