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

FlatEventStreamRecord

class FlatEventStreamRecord(val id: String, rawAggregateId: AggregateId, val header: ObjectNode, val version: Int, val commandId: String, val requestId: String, val body: JsonNode, val createTime: Long) : EventStreamRecord

Constructors

FlatEventStreamRecord

constructor(id: String, rawAggregateId: AggregateId, header: ObjectNode, version: Int, commandId: String, requestId: String, body: JsonNode, createTime: Long)

Properties

open override val actual: ObjectNode

open override val aggregateId: String

open override val aggregateName: String

open override val body: JsonNode

open override val commandId: String

open override val contextName: String

open override val createTime: Long

open override val header: ObjectNode

open override val id: String

open override val requestId: String

open override val tenantId: String

open override val version: Int

Functions

getContextAlias

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

isSameBoundedContext

open fun isSameBoundedContext(other: NamedBoundedContext): Boolean

open override fun toAggregateId(): AggregateId

toDomainEventStream

open fun toDomainEventStream(): DomainEventStream

toMessageHeader

open fun toMessageHeader(): Header