wow-core/me.ahoo.wow.modeling.state/SourcingVersionConflictException

SourcingVersionConflictException

class SourcingVersionConflictException(val eventStream: DomainEventStream, val expectVersion: Int, cause: Throwable? = null) : WowException, NamedAggregate

Constructors

SourcingVersionConflictException

constructor(eventStream: DomainEventStream, expectVersion: Int, cause: Throwable? = null)

Properties

open override val aggregateName: String

open override val bindingErrors: List<BindingError>

optional list of field-level validation errors

open val cause: Throwable?

open override val contextName: String

override val errorCode: String

the standardized error code for this exception

open override val errorMsg: String

the error message

val eventStream: DomainEventStream

val expectVersion: Int

localizedMessage

open val localizedMessage: String?

open override val message: String

val Throwable.recoverable: RecoverableType

Determines the recoverable type of this Throwable.

open var stackTrace: Array<out StackTraceElement?>?

open val succeeded: Boolean

val suppressed: Array<out Throwable?>?

Functions

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

Creates an AggregateId for this NamedAggregate with the specified parameters.

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

Finds the aggregate type class associated with this named aggregate.

asAggregateMetadata

fun <C : Any, S : Any> NamedAggregate.asAggregateMetadata(): AggregateMetadata<C, S>

Converts this NamedAggregate to its corresponding AggregateMetadata.

fun NamedAggregate.generateId(): String

Generates a unique ID string for this NamedAggregate.

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.

fun NamedAggregate.isLocal(): Boolean

Checks if the named aggregate is available locally at runtime.

isSameAggregateName

open override fun isSameAggregateName(other: NamedAggregate): Boolean

isSameBoundedContext

open override fun isSameBoundedContext(other: NamedBoundedContext): Boolean

fun NamedAggregate.materialize(): MaterializedNamedAggregate

Materializes this NamedAggregate into a MaterializedNamedAggregate.

requiredAggregateType

fun <T> NamedAggregate.requiredAggregateType(): Class<T>

Finds the aggregate type class associated with this named aggregate, throwing an exception if not found.

fun Throwable.toErrorInfo(): ErrorInfo

Converts this Throwable to standardized ErrorInfo.

toEventNamedAggregate

fun NamedAggregate.toEventNamedAggregate(eventName: String): EventNamedAggregate

Extension function to convert a NamedAggregate to an EventNamedAggregate.

toNamedAggregateString

fun NamedAggregate.toNamedAggregateString(): String

Converts this NamedAggregate to its string representation.

fun Throwable.toResult(waitCommandId: String, commandMessage: CommandMessage<*>, function: FunctionInfoData = COMMAND_GATEWAY_FUNCTION, id: String = generateGlobalId(), stage: CommandStage = CommandStage.SENT, result: Map<String, Any> = emptyMap(), signalTime: Long = System.currentTimeMillis()): CommandResult

Converts a Throwable to a CommandResult representing a command failure.

toStringWithAlias

fun NamedAggregate.toStringWithAlias(): String

Converts this NamedAggregate to a string representation using the context alias.