Uses of Record Class
io.axoniq.framework.messaging.queryhandling.distributed.DistributedQueryBusConfiguration

Packages that use DistributedQueryBusConfiguration

Package	Description
io.axoniq.framework.messaging.queryhandling.distributed	Part of the Axon Messaging module.

Uses of DistributedQueryBusConfiguration in io.axoniq.framework.messaging.queryhandling.distributed

Fields in io.axoniq.framework.messaging.queryhandling.distributed declared as DistributedQueryBusConfiguration

Modifier and Type	Field	Description
static final DistributedQueryBusConfiguration	DistributedQueryBusConfiguration.DEFAULT	A default instance of the DistributedQueryBusConfiguration, setting the queryThreads() to 10, the queryQueueCapacity() to 1000, the executorServiceFactory() to a priority-aware ExecutorServiceFactory using the configured number of threads, and preferLocalQueryHandler() to true.

Methods in io.axoniq.framework.messaging.queryhandling.distributed that return DistributedQueryBusConfiguration

Modifier and Type	Method	Description
DistributedQueryBusConfiguration	DistributedQueryBusConfiguration.preferLocalQueryHandler(boolean preferLocalQueryHandler)	Configures whether the distributed query bus should use local query handlers directly when available, bypassing remote dispatch.
DistributedQueryBusConfiguration	DistributedQueryBusConfiguration.queryExecutorService(ExecutorService executorService)	Sets the ExecutorService to use for querying in the distributed query bus.
DistributedQueryBusConfiguration	DistributedQueryBusConfiguration.queryQueueCapacity(int queryQueueCapacity)	Sets the capacity of the priority queue used for query processing tasks.
DistributedQueryBusConfiguration	DistributedQueryBusConfiguration.queryThreads(int queryThreads)	Sets the number of threads to use for the distributed query bus.

Methods in io.axoniq.framework.messaging.queryhandling.distributed that return types with arguments of type DistributedQueryBusConfiguration

Modifier and Type	Method	Description
ExecutorServiceFactory<DistributedQueryBusConfiguration>	DistributedQueryBusConfiguration.executorServiceFactory()	Returns the value of the executorServiceFactory record component.

Constructors in io.axoniq.framework.messaging.queryhandling.distributed with parameters of type DistributedQueryBusConfiguration

Modifier	Constructor	Description
	DistributedQueryBus(QueryBus localSegment, QueryBusConnector connector, DistributedQueryBusConfiguration configuration)	Constructs a DistributedQueryBus using the given localSegment for subscribing handlers and the given connector to dispatch and receive queries and query responses with, to and from different segments of the QueryBus.

Constructor parameters in io.axoniq.framework.messaging.queryhandling.distributed with type arguments of type DistributedQueryBusConfiguration

Modifier	Constructor	Description
	DistributedQueryBusConfiguration(int queryThreads, int queryQueueCapacity, ExecutorServiceFactory<DistributedQueryBusConfiguration> executorServiceFactory, boolean preferLocalQueryHandler)	Compact constructor validating that the given queryThreads and queryQueueCapacity are strictly positive.