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

Package-level declarations

Types

AggregateCommandDispatcher

class AggregateCommandDispatcher<C : Any, S : Any>(val aggregateMetadata: AggregateMetadata<C, S>, val parallelism: Int = MessageParallelism.DEFAULT_PARALLELISM, val scheduler: Scheduler, val messageFlux: Flux<ServerCommandExchange<*>>, val name: String = "-", aggregateProcessorFactory: AggregateProcessorFactory, commandHandler: CommandHandler, serviceProvider: ServiceProvider) : AggregateMessageDispatcher<ServerCommandExchange<*>>

Aggregate Command Dispatcher Grouped by NamedAggregate.

----

AggregateProcessor

interface AggregateProcessor<C : Any> : AggregateIdCapable, NamedTypedAggregate<C> , MonoMessageProcessor<C, ServerCommandExchange<*>, Mono<DomainEventStream>>

AggregateProcessorFactory

interface AggregateProcessorFactory

AggregateProcessorFilter

@Order(value = 0)

object AggregateProcessorFilter : ExchangeFilter<ServerCommandExchange<*>>

CommandAggregate

interface CommandAggregate<C : Any, S : Any> : NamedTypedAggregate<C> , AggregateProcessor<C> , Version

Command Aggregate .

CommandAggregateFactory

interface CommandAggregateFactory

Command Aggregate Factory .

CommandDispatcher

class CommandDispatcher(val name: String = CommandDispatcher::class.simpleName!!, val parallelism: Int = MessageParallelism.DEFAULT_PARALLELISM, val namedAggregates: Set<NamedAggregate> = MetadataSearcher.localAggregates, commandBus: CommandBus, aggregateProcessorFactory: AggregateProcessorFactory, commandHandler: CommandHandler, serviceProvider: ServiceProvider, schedulerSupplier: AggregateSchedulerSupplier = DefaultAggregateSchedulerSupplier("CommandDispatcher")) : AbstractDispatcher<ServerCommandExchange<*>>

Command Dispatcher .

CommandExpectVersionConflictException

class CommandExpectVersionConflictException(val command: CommandMessage<*>, val expectVersion: Int, val actualVersion: Int, errorMsg: String = "The expected version[") : WowException

CommandFunction

class CommandFunction<C : Any>(val delegate: MessageFunction<C, ServerCommandExchange<*>, Mono<*>>, commandAggregate: CommandAggregate<C, *>) : MessageFunction<C, ServerCommandExchange<*>, Mono<DomainEventStream>> , Decorator<MessageFunction<C, ServerCommandExchange<*>, Mono<*>>>

interface CommandHandler : Handler<ServerCommandExchange<*>>

enum CommandState : Enum<CommandState>

DefaultCommandHandler

class DefaultCommandHandler(chain: FilterChain<ServerCommandExchange<*>>, errorHandler: ErrorHandler<ServerCommandExchange<*>> = LogResumeErrorHandler()) : AbstractHandler<ServerCommandExchange<*>> , CommandHandler

DefaultDeleteAggregateFunction

class DefaultDeleteAggregateFunction<C : Any>(commandAggregate: CommandAggregate<C, *>) : MessageFunction<C, ServerCommandExchange<*>, Mono<DomainEventStream>>

DefaultRecoverAggregateFunction

class DefaultRecoverAggregateFunction<C : Any>(commandAggregate: CommandAggregate<C, *>) : MessageFunction<C, ServerCommandExchange<*>, Mono<DomainEventStream>>

IllegalAccessDeletedAggregateException

class IllegalAccessDeletedAggregateException(val aggregateId: AggregateId, errorMsg: String = "Illegal access to a deleted aggregate[") : WowException

RetryableAggregateProcessor

class RetryableAggregateProcessor<C : Any, S : Any>(val aggregateId: AggregateId, aggregateMetadata: AggregateMetadata<C, S>, aggregateFactory: StateAggregateFactory, stateAggregateRepository: StateAggregateRepository, commandAggregateFactory: CommandAggregateFactory) : AggregateProcessor<C> , NamedTypedAggregate<C>

RetryableAggregateProcessorFactory

class RetryableAggregateProcessorFactory(stateAggregateFactory: StateAggregateFactory, stateAggregateRepository: StateAggregateRepository, commandAggregateFactory: CommandAggregateFactory) : AggregateProcessorFactory

SendDomainEventStreamFilter

@Order(value = 2147483647, after = [AggregateProcessorFilter::class])

class SendDomainEventStreamFilter(domainEventBus: DomainEventBus) : ExchangeFilter<ServerCommandExchange<*>>

SimpleCommandAggregate

class SimpleCommandAggregate<C : Any, S : Any>(val state: StateAggregate<S>, val commandRoot: C, eventStore: EventStore, metadata: CommandAggregateMetadata<C>) : CommandAggregate<C, S> , NamedTypedAggregate<C>

SimpleCommandAggregateFactory

class SimpleCommandAggregateFactory(eventStore: EventStore) : CommandAggregateFactory

Properties

COMMAND_AGGREGATE_KEY

const val COMMAND_AGGREGATE_KEY: String

Functions

getCommandAggregate

fun <C : Any, S : Any> ServerCommandExchange<*>.getCommandAggregate(): CommandAggregate<C, S>?

setCommandAggregate

fun ServerCommandExchange<*>.setCommandAggregate(commandAggregate: CommandAggregate<*, *>): ServerCommandExchange<*>