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

DistributedCommandBus

interface DistributedCommandBus : CommandBus, DistributedMessageBus<CommandMessage<*>, ServerCommandExchange<*>>

Inheritors

Properties

Link copied to clipboard
open override val topicKind: TopicKind

Functions

Link copied to clipboard
open override fun close()
Link copied to clipboard
Link copied to clipboard
abstract fun receive(namedAggregates: Set<NamedAggregate>): Flux<ServerCommandExchange<*>>
Link copied to clipboard
abstract fun send(message: CommandMessage<*>): Mono<Void>