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

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 .

Author

ahoo wang

Constructors

CommandDispatcher

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"))

Properties

name

open override val name: String

namedAggregates

open override val namedAggregates: Set<NamedAggregate>

must be me.ahoo.wow.modeling.MaterializedNamedAggregate

parallelism

val parallelism: Int

Functions

open override fun close()

newAggregateDispatcher

open override fun newAggregateDispatcher( namedAggregate: NamedAggregate, messageFlux: Flux<ServerCommandExchange<*>>): MessageDispatcher

receiveMessage

open override fun receiveMessage(namedAggregate: NamedAggregate): Flux<ServerCommandExchange<*>>

run

open override fun run()