Uses of Record Class
io.axoniq.framework.messaging.queryhandling.distributed.DistributedQueryBusConfiguration
Packages that use DistributedQueryBusConfiguration
Package
Description
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 DistributedQueryBusConfigurationModifier and TypeFieldDescriptionstatic final DistributedQueryBusConfigurationDistributedQueryBusConfiguration.DEFAULTA default instance of theDistributedQueryBusConfiguration, setting thequeryThreads()to 10, thequeryQueueCapacity()to 1000, theexecutorServiceFactory()to a priority-awareExecutorServiceFactoryusing the configured number of threads, andpreferLocalQueryHandler()totrue.Methods in io.axoniq.framework.messaging.queryhandling.distributed that return DistributedQueryBusConfigurationModifier and TypeMethodDescriptionDistributedQueryBusConfiguration.preferLocalQueryHandler(boolean preferLocalQueryHandler) Configures whether the distributed query bus should use local query handlers directly when available, bypassing remote dispatch.DistributedQueryBusConfiguration.queryExecutorService(ExecutorService executorService) Sets theExecutorServiceto use for querying in the distributed query bus.DistributedQueryBusConfiguration.queryQueueCapacity(int queryQueueCapacity) Sets the capacity of the priority queue used for query processing tasks.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 DistributedQueryBusConfigurationModifier and TypeMethodDescriptionDistributedQueryBusConfiguration.executorServiceFactory()Returns the value of theexecutorServiceFactoryrecord component.Constructors in io.axoniq.framework.messaging.queryhandling.distributed with parameters of type DistributedQueryBusConfigurationModifierConstructorDescriptionDistributedQueryBus(QueryBus localSegment, QueryBusConnector connector, DistributedQueryBusConfiguration configuration) Constructs aDistributedQueryBususing the givenlocalSegmentforsubscribinghandlers and the givenconnectorto dispatch and receive queries and query responses with, to and from different segments of theQueryBus.Constructor parameters in io.axoniq.framework.messaging.queryhandling.distributed with type arguments of type DistributedQueryBusConfigurationModifierConstructorDescriptionDistributedQueryBusConfiguration(int queryThreads, int queryQueueCapacity, ExecutorServiceFactory<DistributedQueryBusConfiguration> executorServiceFactory, boolean preferLocalQueryHandler) Compact constructor validating that the givenqueryThreadsandqueryQueueCapacityare strictly positive.