Package io.axoniq.framework.messaging.commandhandling.distributed

@NullMarked package io.axoniq.framework.messaging.commandhandling.distributed

Part of the Axon Messaging module. Contains classes related to command distribution.

Related Packages

Package	Description
io.axoniq.framework.messaging.commandhandling.distributed.tracing	Internal delegating tracing decorator for the distributed CommandBusConnector.

Class	Description
CommandBusConnector	The CommandBusConnector interface defines the contract for connecting multiple CommandBus instances.
CommandBusConnector.Handler	A functional interface representing a handler for incoming command messages.
CommandBusConnector.ResultCallback	A callback interface for handling the result of command processing.
DelegatingCommandBusConnector	A CommandBusConnector implementation that wraps another CommandBusConnector and delegates all calls to it.
DistributedCommandBus	Implementation of a CommandBus that is aware of multiple instances of a CommandBus working together to spread load.
DistributedCommandBusConfiguration	Configuration for the DistributedCommandBus.
DistributedCommandBusConfigurationEnhancer	Configuration enhancer for the DistributedCommandBus, which upon detection of a CommandBusConnector in the configuration will decorate the regular CommandBus with the provided connector.
LocalCommandDispatchPredicate	Predicate deciding whether a CommandMessage that is about to be dispatched through a CommandBusConnector should be handled by the local segment directly (taking a "local shortcut") instead of being routed by the connector, which might hand the command to a different segment.
LocalShortcutCommandBusConnector	A CommandBusConnector that offers a "local shortcut".
LocalShortcutCommandBusConnectorConfigurationEnhancer	A ConfigurationEnhancer that when a CommandBusConnector is present in the configuration may decorate it with a LocalShortcutCommandBusConnector wrapping a registered LocalCommandDispatchPredicate.
PayloadConvertingCommandBusConnector	Connector implementation that converts the payload of outgoing messages into the expected format.