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.

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.
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.