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

CommandAggregate

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

Represents a command aggregate that processes commands and manages state transitions.

A command aggregate subscribes to command messages, validates business rules using the current state from the state aggregate, and publishes domain events. It coordinates between command processing and state management.

Key responsibilities:

Subscribe to command messages
Validate business rules using state aggregate's current state
Publish domain events

Parameters

The type of the command aggregate root.

The type of the state aggregate.

Inheritors

SimpleCommandAggregate

Properties

aggregateId

open override val aggregateId: AggregateId

aggregateName

abstract val aggregateName: String

aggregateType

abstract val aggregateType: Class<C>

commandRoot

abstract val commandRoot: C

The command aggregate root instance.

commandState

abstract val commandState: CommandState

The current state of command processing.

contextName

abstract val contextName: String

initialized

open val initialized: Boolean

isInitialVersion

open val isInitialVersion: Boolean

processorName

abstract val processorName: String

state

abstract val state: StateAggregate<S>

The associated state aggregate containing the current state.

version

open override val version: Int

Functions

aggregateId

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

Creates an AggregateId for this NamedAggregate with the specified parameters.

aggregateType

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.

generateId

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.

isLocal

fun NamedAggregate.isLocal(): Boolean

Checks if the named aggregate is available locally at runtime.

isSameAggregateName

open fun isSameAggregateName(other: NamedAggregate): Boolean

isSameBoundedContext

open fun isSameBoundedContext(other: NamedBoundedContext): Boolean

materialize

fun NamedAggregate.materialize(): MaterializedNamedAggregate

Materializes this NamedAggregate into a MaterializedNamedAggregate.

process

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

Processes a command exchange for this aggregate instance.

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.

toGroupKey

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.