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

SimpleCommandAggregate

class SimpleCommandAggregate<C : Any, S : Any>(val state: StateAggregate<S>, val commandRoot: C, eventStore: EventStore, metadata: CommandAggregateMetadata<C>) : CommandAggregate<C, S> , NamedTypedAggregate<C>

Simple implementation of CommandAggregate that handles command processing with state management.

This class coordinates between command execution, state aggregation, and event storage. It manages the command processing lifecycle including validation, execution, event sourcing, and persistence.

Parameters

The type of the command aggregate root.

The type of the state aggregate.

eventStore

The event store for persisting domain events.

metadata

The metadata describing this command aggregate's configuration.

Constructors

SimpleCommandAggregate

constructor(state: StateAggregate<S>, commandRoot: C, eventStore: EventStore, metadata: CommandAggregateMetadata<C>)

Properties

aggregateId

open override val aggregateId: AggregateId

aggregateName

open override val aggregateName: String

aggregateType

open override val aggregateType: Class<C>

commandRoot

open override val commandRoot: C

The command aggregate root instance.

commandState

@Volatile

open override var commandState: CommandState

The current state of command processing.

contextName

open override val contextName: String

initialized

open val initialized: Boolean

isInitialVersion

open val isInitialVersion: Boolean

processorName

open override val processorName: String

state

open override 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 override fun isSameAggregateName(other: NamedAggregate): Boolean

isSameBoundedContext

open override fun isSameBoundedContext(other: NamedBoundedContext): Boolean

materialize

fun NamedAggregate.materialize(): MaterializedNamedAggregate

Materializes this NamedAggregate into a MaterializedNamedAggregate.

process

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

Processes a command exchange by validating, executing, and persisting the results.

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.

toString

open override fun toString(): String

toStringWithAlias

fun NamedAggregate.toStringWithAlias(): String

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