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

CommandDispatcher

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"), metrics: WowMetrics = WowMetrics.NONE) : MainDispatcher<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, commandHandler: CommandHandler, schedulerSupplier: AggregateSchedulerSupplier = DefaultAggregateSchedulerSupplier("CommandDispatcher"), metrics: WowMetrics = WowMetrics.NONE)

Properties

name

open override val name: String

namedAggregates

open override val namedAggregates: Set<NamedAggregate>

The set of named aggregates that this dispatcher will manage.

parallelism

val parallelism: Int

Functions

newAggregateDispatcher

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

Creates a new message dispatcher for a specific named aggregate.

receiveMessage

open override fun receiveMessage(subscription: MessageSubscription): Flux<ServerCommandExchange<*>>

Creates a flux of messages for the specified subscription.