Package-level declarations
Types
Link copied to clipboard
class AggregateCommandDispatcher<C : Any, S : Any>(val name: String = "-", val aggregateMetadata: AggregateMetadata<C, S>, val messageFlux: Flux<ServerCommandExchange<*>>, val parallelism: Int = MessageParallelism.DEFAULT_PARALLELISM, commandHandler: CommandHandler, val scheduler: Scheduler) : AggregateDispatcher<ServerCommandExchange<*>>
Aggregate command dispatcher grouped by named aggregate.
Link copied to clipboard
class AggregateProcessorFilter(serviceProvider: ServiceProvider, aggregateProcessorFactory: AggregateProcessorFactory) : CommandFilter
Link copied to clipboard
class CommandDispatcher(val name: String = CommandDispatcher::class.simpleName!!, val parallelism: Int = MessageParallelism.DEFAULT_PARALLELISM, val namedAggregates: Set<NamedAggregate> = MetadataSearcher.localAggregates, commandBus: CommandBus, commandHandler: CommandHandler, schedulerSupplier: AggregateSchedulerSupplier = DefaultAggregateSchedulerSupplier("CommandDispatcher")) : MainDispatcher<ServerCommandExchange<*>>
Command Dispatcher .
Link copied to clipboard
Link copied to clipboard
Handler interface for processing command exchanges.
Link copied to clipboard
class DefaultCommandHandler(chain: FilterChain<ServerCommandExchange<*>>, errorHandler: ErrorHandler<ServerCommandExchange<*>> = LogResumeErrorHandler()) : AbstractHandler<ServerCommandExchange<*>> , CommandHandler
Default implementation of CommandHandler using a filter chain.
Link copied to clipboard