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

SimpleCommandMessage

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

Constructors

SimpleCommandMessage

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

Properties

open override val aggregateId: AggregateId

open override val aggregateName: String

aggregateVersion

open override val aggregateVersion: Int? = null

open override val allowCreate: Boolean = false

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 = false

open val isReadOnly: Boolean

open override val name: String

open override val requestId: String

Functions

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

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

open override fun copy(): CommandMessage<C>

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

fun NamedAggregate.generateId(): String

getContextAlias

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

fun NamedAggregate.isLocal(): Boolean

isSameAggregateName

open override fun isSameAggregateName(other: NamedAggregate): Boolean

isSameBoundedContext

open override fun isSameBoundedContext(other: NamedBoundedContext): Boolean

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

fun NamedAggregate.materialize(): MaterializedNamedAggregate

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

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

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

open fun withReadOnly(): CommandMessage<C>