wow-core/me.ahoo.wow.command/DuplicateRequestIdException

DuplicateRequestIdException

class DuplicateRequestIdException(val aggregateId: AggregateId, val requestId: String, errorMsg: String = "Duplicate request ID[", cause: Throwable? = null) : WowException, NamedAggregate

Exception thrown when a duplicate request ID is detected.

This exception occurs when attempting to process a command with a request ID that has already been processed for the same aggregate, preventing duplicate command execution.

Parameters

aggregateId

the aggregate for which the duplicate was detected

requestId

the duplicate request identifier

errorMsg

custom error message (default provided)

cause

the underlying cause (optional)

Constructors

DuplicateRequestIdException

constructor(aggregateId: AggregateId, requestId: String, errorMsg: String = "Duplicate request ID[", cause: Throwable? = null)

Properties

aggregateId

val aggregateId: AggregateId

aggregateName

open override val aggregateName: String

bindingErrors

open override val bindingErrors: List<BindingError>

optional list of field-level validation errors

cause

open val cause: Throwable?

contextName

open override val contextName: String

errorCode

override val errorCode: String

the standardized error code for this exception

errorMsg

open override val errorMsg: String

the error message

localizedMessage

open val localizedMessage: String?

message

open override val message: String

recoverable

val Throwable.recoverable: RecoverableType

Determines the recoverable type of this Throwable.

requestId

val requestId: String

stackTrace

open var stackTrace: Array<out StackTraceElement?>?

succeeded

open val succeeded: Boolean

suppressed

val suppressed: Array<out Throwable?>?

Functions

aggregateId

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

Creates an AggregateId for this NamedAggregate with the specified parameters.

aggregateType

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.

generateId

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.

isLocal

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

materialize

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.

toErrorInfo

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.

toResult

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.

DuplicateRequestIdException

Parameters

See also

Constructors

Properties

Functions