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>

Constructors

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

commandState

@Volatile

open override var commandState: CommandState

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>

version

open override val version: Int

Functions

aggregateId

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

aggregateType

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

generateId

fun NamedAggregate.generateId(): String

getContextAlias

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

isLocal

fun NamedAggregate.isLocal(): Boolean

isSameAggregateName

open override fun isSameAggregateName(other: NamedAggregate): Boolean

isSameBoundedContext

open override fun isSameBoundedContext(other: NamedBoundedContext): Boolean

materialize

fun NamedAggregate.materialize(): MaterializedNamedAggregate

process

open 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

toGroupKey

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

toNamedAggregateString

fun NamedAggregate.toNamedAggregateString(): String

toString

open override fun toString(): String

toStringWithAlias

fun NamedAggregate.toStringWithAlias(): String