Package io.axoniq.framework.messaging.queryhandling.distributed

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

Part of the Axon Messaging module. Contains classes related to distributed.

Related Packages

Package	Description
io.axoniq.framework.messaging.queryhandling.distributed.tracing	Internal delegating tracing decorator for the distributed QueryBusConnector.

Class	Description
DelegatingQueryBusConnector	A QueryBusConnector implementation that wraps another QueryBusConnector and delegates all calls to it.
DistributedQueryBus	Implementation of a QueryBus that is aware of multiple instances of a QueryBus working together to spread the load.
DistributedQueryBusConfiguration	Configuration for the DistributedQueryBus.
DistributedQueryBusConfigurationEnhancer	Configuration enhancer for the DistributedQueryBus, which upon detection of a QueryBusConnector in the configuration will decorate the regular QueryBus with the provided connector.
LocalQueryDispatchPredicate	Predicate deciding whether a QueryMessage that is about to be dispatched through a QueryBusConnector should be handled by the local segment directly (taking a "local shortcut") instead of being routed by the connector, which may hand the query to a different segment.
LocalShortcutQueryBusConnector	A QueryBusConnector that offers a "local shortcut".
LocalShortcutQueryBusConnectorConfigurationEnhancer	A ConfigurationEnhancer that when a QueryBusConnector is present in the configuration may decorate it with a LocalShortcutQueryBusConnector wrapping a registered LocalQueryDispatchPredicate.
PayloadConvertingQueryBusConnector	Connector implementation that converts the payload of outgoing messages into the expected format.
QueryBusConnector	The QueryBusConnector interface defines the contract for connecting multiple QueryBus instances.
QueryBusConnector.Handler	Defines a handler for processing query messages and managing subscription queries.
QueryBusConnector.UpdateCallback	Defines a callback mechanism to handle update messages for subscription queries in a reactive and asynchronous manner.