wow-core/me.ahoo.wow.event.upgrader/MutableDomainEventRecord

MutableDomainEventRecord

class MutableDomainEventRecord(val actual: ObjectNode, actualAggregateId: AggregateId, actualHeader: Header, val version: Int, val ownerId: String, val spaceId: SpaceId, val commandId: String, val sequence: Int, val isLast: Boolean, val createTime: Long) : DomainEventRecord

Mutable wrapper for domain event records.

This class provides a mutable interface to domain event records stored as Jackson ObjectNode instances. It allows modification of event properties during the upgrading process.

Parameters

actualAggregateId

The aggregate identifier represented by the record

actualHeader

The message header represented by the record

See also

DomainEventRecord

ObjectNode

Constructors

MutableDomainEventRecord

constructor(actual: ObjectNode, actualAggregateId: AggregateId, actualHeader: Header, version: Int, ownerId: String, spaceId: SpaceId, commandId: String, sequence: Int, isLast: Boolean, createTime: Long)

Creates a new MutableDomainEventRecord wrapping the given ObjectNode

Types

object Companion

Properties

open override val actual: ObjectNode

The underlying ObjectNode containing the event data

open override val aggregateId: String

open override val aggregateName: String

open override var body: ObjectNode

The body of the event as an ObjectNode, mutable for upgrading.

open override var bodyType: String

The body type of the event, mutable for upgrading.

open override val commandId: String

The command identifier

open override val contextName: String

open override val createTime: Long

The event creation timestamp

open val header: ObjectNode

open val id: String

open override val isLast: Boolean

Whether this is the last event in the stream

open override var name: String

The name of the event, mutable for upgrading.

open override val ownerId: String

The owner identifier

open override var revision: String

The revision of the event, mutable for upgrading.

open override val sequence: Int

The event sequence

open override val spaceId: SpaceId

The space identifier

open override val tenantId: String

open override val version: Int

The aggregate version

Functions

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.

isSameBoundedContext

open fun isSameBoundedContext(other: NamedBoundedContext): Boolean

open override fun toAggregateId(): AggregateId

open fun toDomainEvent(): DomainEvent<Any>

toDroppedEventRecord

fun DomainEventRecord.toDroppedEventRecord(): DomainEventRecord

Converts a domain event record to a dropped event record.

fun DomainEventRecord.toEventTypeId(): EventTypeId

toMessageHeader

open override fun toMessageHeader(): Header

toMutableDomainEventRecord

fun DomainEventRecord.toMutableDomainEventRecord(): MutableDomainEventRecord

Extension function to convert a DomainEventRecord to a MutableDomainEventRecord.