wow-core/me.ahoo.wow.modeling.command/CommandAggregate

CommandAggregate

interface CommandAggregate<C : Any, S : Any> : NamedTypedAggregate<C> , AggregateProcessor<C> , Version

Command Aggregate .

订阅命令消息
依赖状态聚合持有的聚合状态，验证业务规则
发布领域事件

订阅命令消息，并依赖状态聚合的当前状态验证业务规则.

Author

ahoo wang

Inheritors

SimpleCommandAggregate

Properties

open override val aggregateId: AggregateId

abstract val aggregateName: String

abstract val aggregateType: Class<C>

abstract val commandRoot: C

abstract val commandState: CommandState

abstract val contextName: String

open val initialized: Boolean

isInitialVersion

open val isInitialVersion: Boolean

abstract val processorName: String

abstract val state: StateAggregate<S>

open override val version: Int

Functions

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

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

fun NamedAggregate.generateId(): String

getContextAlias

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

fun NamedAggregate.isLocal(): Boolean

isSameAggregateName

open fun isSameAggregateName(other: NamedAggregate): Boolean

isSameBoundedContext

open fun isSameBoundedContext(other: NamedBoundedContext): Boolean

fun NamedAggregate.materialize(): MaterializedNamedAggregate

abstract override fun process(exchange: ServerCommandExchange<*>): Mono<DomainEventStream>

Processing of commands must be serial.

requiredAggregateType

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

toEventNamedAggregate

fun NamedAggregate.toEventNamedAggregate(eventName: String): EventNamedAggregate

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

toNamedAggregateString

fun NamedAggregate.toNamedAggregateString(): String

toStringWithAlias

fun NamedAggregate.toStringWithAlias(): String