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

CommandGateway

interface CommandGateway : CommandBus

Command Gateway .

Author

ahoo wang

See also

Inheritors

Properties

Link copied to clipboard
open override val topicKind: TopicKind

Functions

Link copied to clipboard
open override fun close()
Link copied to clipboard
abstract fun receive(namedAggregates: Set<NamedAggregate>): Flux<ServerCommandExchange<*>>
Link copied to clipboard
abstract fun <C : Any> send(command: CommandMessage<C>, waitStrategy: WaitStrategy): Mono<out ClientCommandExchange<C>>
abstract fun send(message: CommandMessage<*>): Mono<Void>
Link copied to clipboard
open fun <C : Any> sendAndWait(command: CommandMessage<C>, waitStrategy: WaitStrategy): Mono<CommandResult>
Link copied to clipboard
open fun <C : Any> sendAndWaitForProcessed(command: CommandMessage<C>): Mono<CommandResult>
Link copied to clipboard
open fun <C : Any> sendAndWaitForSent(command: CommandMessage<C>): Mono<CommandResult>
Link copied to clipboard
open fun <C : Any> sendAndWaitForSnapshot(command: CommandMessage<C>): Mono<CommandResult>