5.3.8

wow-core/me.ahoo.wow.serialization.event/JsonDomainEvent

JsonDomainEvent

data class JsonDomainEvent(val id: String, val header: Header, val bodyType: String, val body: JsonNode, val aggregateId: AggregateId, val ownerId: String, val version: Int, val sequence: Int, val revision: String, val commandId: String, val name: String, val isLast: Boolean = true, val createTime: Long = System.currentTimeMillis()) : DomainEvent<JsonNode> , NamedAggregate

Constructors

JsonDomainEvent

constructor(id: String, header: Header, bodyType: String, body: JsonNode, aggregateId: AggregateId, ownerId: String, version: Int, sequence: Int, revision: String, commandId: String, name: String, isLast: Boolean = true, createTime: Long = System.currentTimeMillis())

Properties

open override val aggregateId: AggregateId

open override val aggregateName: String

open override val body: JsonNode

val bodyType: String

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 val initialized: Boolean

isInitialVersion

open val isInitialVersion: Boolean

open override val isLast: Boolean = true

open val isReadOnly: Boolean

open override val name: String

open override val ownerId: String

open override val revision: String

open override val sequence: Int

open override val version: Int

Functions

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

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

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 DomainEvent<out ErrorInfo>.toException(): DomainEventException

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>): DomainEvent<JsonNode>

open fun withHeader(key: String, value: String): DomainEvent<JsonNode>

open fun withReadOnly(): DomainEvent<JsonNode>