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

LocalFirstCommandBus

class LocalFirstCommandBus(val distributedBus: DistributedCommandBus, val localBus: LocalCommandBus = InMemoryCommandBus()) : CommandBus, LocalFirstMessageBus<CommandMessage<*>, ServerCommandExchange<*>>

Constructors

LocalFirstCommandBus

constructor(distributedBus: DistributedCommandBus, localBus: LocalCommandBus = InMemoryCommandBus())

Properties

open override val distributedBus: DistributedCommandBus

open override val localBus: LocalCommandBus

open override val topicKind: TopicKind

Functions

open override fun close()

abstract fun receive(namedAggregates: Set<NamedAggregate>): Flux<ServerCommandExchange<*>>

abstract fun send(message: CommandMessage<*>): Mono<Void>