Package org.axonframework.messaging.queryhandling.distributed
package org.axonframework.messaging.queryhandling.distributed
-
ClassDescriptionA
QueryBusConnectorimplementation that wraps anotherQueryBusConnectorand delegates all calls to it.Implementation of aQueryBusthat is aware of multiple instances of aQueryBusworking together to spread the load.Configuration for theDistributedQueryBus.Configuration enhancer for theDistributedQueryBus, which upon detection of aQueryBusConnectorin the configuration will decorate the regularQueryBuswith the provided connector.Connector implementation that converts the payload of outgoing messages into the expected format.TheQueryBusConnectorinterface defines the contract for connecting multipleQueryBusinstances.Defines a handler for processing query messages and managing subscription queries.Defines a callback mechanism to handle update messages for subscription queries in a reactive and asynchronous manner.