wow-core/me.ahoo.wow.command

Package-level declarations

Types

ClientCommandExchange

interface ClientCommandExchange<C : Any> : CommandExchange<ClientCommandExchange<C>, C>

CommandBus

interface CommandBus : MessageBus<CommandMessage<*>, ServerCommandExchange<*>> , TopicKindCapable

Command Bus .

CommandExchange

interface CommandExchange<SOURCE : CommandExchange<SOURCE, C>, C : Any> : MessageExchange<SOURCE, CommandMessage<C>>

Command Exchange .

CommandGateway

interface CommandGateway : CommandBus

Command Gateway .

CommandOperator

object CommandOperator

CommandResult

data class CommandResult(val stage: CommandStage, val aggregateId: String, val contextName: String, val processorName: String, val tenantId: String, val requestId: String, val commandId: String, val errorCode: String = ErrorCodes.SUCCEEDED, val errorMsg: String = ErrorCodes.SUCCEEDED_MESSAGE, val bindingErrors: List<BindingError> = emptyList(), val result: Map<String, Any> = emptyMap()) : CommandId, TenantId, RequestId, ErrorInfo, ProcessorInfo, CommandResultCapable

CommandResultCapable

interface CommandResultCapable

CommandResultException

class CommandResultException(val commandResult: CommandResult, cause: Throwable? = null) : WowException

CommandValidationException

class CommandValidationException(val command: Any, errorMsg: String = "Command validation failed.", cause: Throwable? = null, val bindingErrors: List<BindingError> = emptyList()) : WowException, ErrorInfo

DefaultCommandGateway

class DefaultCommandGateway(commandWaitEndpoint: CommandWaitEndpoint, commandBus: CommandBus, validator: Validator, idempotencyCheckerProvider: AggregateIdempotencyCheckerProvider, waitStrategyRegistrar: WaitStrategyRegistrar) : CommandGateway, CommandBus

DistributedCommandBus

interface DistributedCommandBus : CommandBus, DistributedMessageBus<CommandMessage<*>, ServerCommandExchange<*>>

DuplicateRequestIdException

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

InMemoryCommandBus

class InMemoryCommandBus(val sinkSupplier: (NamedAggregate) -> Sinks.Many<CommandMessage<*>> = { Sinks.many().unicast().onBackpressureBuffer() }) : InMemoryMessageBus<CommandMessage<*>, ServerCommandExchange<*>> , LocalCommandBus

InMemoryCommandBus .

LocalCommandBus

interface LocalCommandBus : CommandBus, LocalMessageBus<CommandMessage<*>, ServerCommandExchange<*>>

LocalFirstCommandBus

class LocalFirstCommandBus(val distributedBus: DistributedCommandBus, val localBus: LocalCommandBus = InMemoryCommandBus()) : CommandBus, LocalFirstMessageBus<CommandMessage<*>, ServerCommandExchange<*>>

ServerCommandExchange

interface ServerCommandExchange<C : Any> : CommandExchange<ServerCommandExchange<C>, C>

SimpleClientCommandExchange

class SimpleClientCommandExchange<C : Any>(val message: CommandMessage<C>, val waitStrategy: WaitStrategy, val attributes: MutableMap<String, Any> = ConcurrentHashMap()) : ClientCommandExchange<C>

SimpleCommandMessage

data class SimpleCommandMessage<C : Any>(val id: String = GlobalIdGenerator.generateAsString(), val header: Header = DefaultHeader.empty(), val body: C, val aggregateId: AggregateId, val requestId: String = id, val aggregateVersion: Int? = null, val name: String = body.javaClass.toName(), val isCreate: Boolean = false, val allowCreate: Boolean = false, val createTime: Long = System.currentTimeMillis()) : CommandMessage<C> , NamedAggregate

SimpleServerCommandExchange

class SimpleServerCommandExchange<C : Any>(val message: CommandMessage<C>, val attributes: MutableMap<String, Any> = ConcurrentHashMap()) : ServerCommandExchange<C>

Properties

AGGREGATE_PROCESSOR_KEY

const val AGGREGATE_PROCESSOR_KEY: String

COMMAND_GATEWAY_FUNCTION

val COMMAND_GATEWAY_FUNCTION: FunctionInfoData

COMMAND_GATEWAY_PROCESSOR_NAME

const val COMMAND_GATEWAY_PROCESSOR_NAME: String

EVENT_STREAM_KEY

const val EVENT_STREAM_KEY: String

Functions

toCommandMessage

fun <C : Any> CommandBuilder.toCommandMessage(): CommandMessage<C>

fun <C : Any> C.toCommandMessage(id: String = GlobalIdGenerator.generateAsString(), requestId: String? = null, aggregateId: String? = null, tenantId: String? = null, aggregateVersion: Int? = null, namedAggregate: NamedAggregate? = null, header: Header = DefaultHeader.empty(), createTime: Long = System.currentTimeMillis(), upstream: DomainEvent<*>? = null): CommandMessage<C>

toResult

fun WaitSignal.toResult(commandMessage: CommandMessage<*>): CommandResult

fun Throwable.toResult(commandMessage: CommandMessage<*>, contextName: String = commandMessage.contextName, processorName: String, stage: CommandStage = CommandStage.SENT, result: Map<String, Any> = emptyMap()): CommandResult