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 .

ahoo wang

Constructors

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

open override val name: String

open override fun close()

open override fun run()