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

StreamDomainEventRecord

class StreamDomainEventRecord(val actual: ObjectNode, streamedAggregateId: AggregateId, streamedVersion: Int, streamedHeader: Header, streamedCommandId: String, val sequence: Int, val isLast: Boolean, streamedCreateTime: Long) : DomainEventRecord

Constructors

StreamDomainEventRecord

constructor(actual: ObjectNode, streamedAggregateId: AggregateId, streamedVersion: Int, streamedHeader: Header, streamedCommandId: String, sequence: Int, isLast: Boolean, streamedCreateTime: Long)

Properties

open override val actual: ObjectNode

open override val aggregateId: String

open override val aggregateName: String

open val body: JsonNode

open val bodyType: String

open override val commandId: String

open override val contextName: String

open override val createTime: Long

open val header: ObjectNode

open val id: String

open override val isLast: Boolean

open override val name: String

open val revision: String

open override val sequence: Int

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

open fun toDomainEvent(): DomainEvent<Any>

toDroppedEventRecord

fun DomainEventRecord.toDroppedEventRecord(): DomainEventRecord

toMessageHeader

open override fun toMessageHeader(): Header

toMutableDomainEventRecord

fun DomainEventRecord.toMutableDomainEventRecord(): MutableDomainEventRecord