wow-core/me.ahoo.wow.command/SimpleCommandMessage

SimpleCommandMessage

data class SimpleCommandMessage<C : Any>(val id: String = generateGlobalId(), val header: Header = DefaultHeader.empty(), val body: C, val aggregateId: AggregateId, val ownerId: String = OwnerId.DEFAULT_OWNER_ID, val requestId: String = id, val aggregateVersion: Int? = null, val name: String = body.javaClass.toName(), val isCreate: Boolean = false, val allowCreate: Boolean = false, val isVoid: Boolean = false, val createTime: Long = System.currentTimeMillis()) : CommandMessage<C> , NamedAggregate

Simple implementation of CommandMessage with default values for most properties. This class provides a convenient way to create command messages with sensible defaults.

Parameters

C

The type of the command body.

id

Unique identifier for the command message. Defaults to a generated global ID.

header

Message header containing metadata. Defaults to an empty header.

body

The actual command payload.

aggregateId

Identifier of the aggregate this command targets.

ownerId

Identifier of the owner/user initiating the command. Defaults to default owner.

requestId

Identifier for request deduplication. Defaults to the message ID.

aggregateVersion

Expected version of the aggregate for optimistic concurrency. Null means no version check.

name

Human-readable name of the command. Defaults to the simple class name of the body.

isCreate

Whether this command creates a new aggregate instance.

allowCreate

Whether creation is allowed if the aggregate doesn't exist.

isVoid

Whether this is a void command that doesn't produce events.

createTime

Timestamp when the command was created. Defaults to current time.

Constructors

SimpleCommandMessage

constructor(id: String = generateGlobalId(), header: Header = DefaultHeader.empty(), body: C, aggregateId: AggregateId, ownerId: String = OwnerId.DEFAULT_OWNER_ID, requestId: String = id, aggregateVersion: Int? = null, name: String = body.javaClass.toName(), isCreate: Boolean = false, allowCreate: Boolean = false, isVoid: Boolean = false, createTime: Long = System.currentTimeMillis())

Properties

open override val aggregateId: AggregateId

open override val aggregateName: String

aggregateVersion

open override val aggregateVersion: Int?

open override val allowCreate: Boolean

open override val body: C

open override val commandId: String

open override val contextName: String

open override val createTime: Long

open override val header: Header

open override val id: String

open override val isCreate: Boolean

open val isReadOnly: Boolean

open override val isVoid: Boolean

open override val name: String

open override val ownerId: String

open override val requestId: String

Functions

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

Creates an AggregateId for this NamedAggregate with the specified parameters.

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.

commandSentSignal

fun CommandMessage<*>.commandSentSignal(waitCommandId: String, error: Throwable? = null): WaitSignal

open override fun copy(): CommandMessage<C>

Creates a copy of this command message with a deep copy of the header. This ensures header modifications don't affect the original message.

fun <C : Any> CommandMessage<C>.ensureTraceId(): CommandMessage<C>

Ensures the command message has a trace ID, using its own ID if none exists.

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.

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

fun Message<*, *>.match(function: FunctionInfo): Boolean

Checks if this message matches the given function for compensation purposes.

fun NamedAggregate.materialize(): MaterializedNamedAggregate

Materializes this NamedAggregate into a MaterializedNamedAggregate.

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.

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.

open fun withHeader(additionalSource: Map<String, String>): CommandMessage<C>

open fun withHeader(key: String, value: String): CommandMessage<C>

open fun withReadOnly(): CommandMessage<C>