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

CommandBus

interface CommandBus : MessageBus<CommandMessage<*>, ServerCommandExchange<*>> , TopicKindCapable

Command Bus interface for handling command messages in the CQRS architecture.

The Command Bus is responsible for routing command messages to their appropriate handlers. It acts as a central hub for command processing, supporting both local and distributed command handling scenarios.

Author

ahoo wang

See also

Inheritors

Properties

Link copied to clipboard
open override val topicKind: TopicKind

The topic kind for command messages, always returns TopicKind.COMMAND

Functions

Link copied to clipboard
open override fun close()

Closes the message bus and releases any resources. Default implementation does nothing.

Link copied to clipboard
abstract fun receive(namedAggregates: Set<NamedAggregate>): Flux<ServerCommandExchange<*>>

Receives messages for the specified named aggregates.

Link copied to clipboard
abstract fun send(message: CommandMessage<*>): Mono<Void>

Sends a message through the message bus.

Generated by Dokka
© 2025 Copyright