Uses of Record Class
org.axonframework.messaging.queryhandling.distributed.DistributedQueryBusConfiguration
Packages that use DistributedQueryBusConfiguration
-
Uses of DistributedQueryBusConfiguration in org.axonframework.messaging.queryhandling.distributed
Fields in org.axonframework.messaging.queryhandling.distributed declared as DistributedQueryBusConfigurationModifier and TypeFieldDescriptionstatic final DistributedQueryBusConfigurationDistributedQueryBusConfiguration.DEFAULTA default instance of theDistributedQueryBusConfiguration, setting thequeryThreads()to 10, thequeryResponseThreads()to 5, and thequeryExecutorServiceFactory()andqueryResponseExecutorServiceFactory()to priority-awareExecutorServiceFactoriesusing the configured number of threads.Methods in org.axonframework.messaging.queryhandling.distributed that return DistributedQueryBusConfigurationModifier and TypeMethodDescriptionDistributedQueryBusConfiguration.queryExecutorService(ExecutorService executorService) Sets theExecutorServiceto use for querying in the distributed query bus.DistributedQueryBusConfiguration.queryResponseExecutorService(ExecutorService executorService) Sets theExecutorServiceto use for handling query responses in the distributed query bus.DistributedQueryBusConfiguration.queryResponseThreads(int queryResponseThreads) Sets the number of threads to use for handling query responses in the distributed query bus.DistributedQueryBusConfiguration.queryThreads(int queryThreads) Sets the number of threads to use for querying in the distributed query bus.Methods in org.axonframework.messaging.queryhandling.distributed that return types with arguments of type DistributedQueryBusConfigurationModifier and TypeMethodDescriptionDistributedQueryBusConfiguration.queryExecutorServiceFactory()Returns the value of thequeryExecutorServiceFactoryrecord component.DistributedQueryBusConfiguration.queryResponseExecutorServiceFactory()Returns the value of thequeryResponseExecutorServiceFactoryrecord component.Constructors in org.axonframework.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 org.axonframework.messaging.queryhandling.distributed with type arguments of type DistributedQueryBusConfigurationModifierConstructorDescriptionDistributedQueryBusConfiguration(int queryThreads, ExecutorServiceFactory<DistributedQueryBusConfiguration> queryExecutorServiceFactory, int queryResponseThreads, ExecutorServiceFactory<DistributedQueryBusConfiguration> queryResponseExecutorServiceFactory) Compact constructor validating that the givenqueryThreadsandqueryResponseThreadsare strictly positive.