Modifier and Type | Field and Description |
---|---|
protected ExecutorFactory |
JournalImpl.ioExecutorFactory |
Constructor and Description |
---|
JournalImpl(ExecutorFactory ioExecutors,
int fileSize,
int minFiles,
int poolSize,
int compactMinFiles,
int compactPercentage,
SequentialFileFactory fileFactory,
String filePrefix,
String fileExtension,
int maxAIO,
int userVersion) |
Constructor and Description |
---|
PagingStoreFactoryDatabase(DatabaseStorageConfiguration dbConf,
StorageManager storageManager,
long syncTimeout,
ScheduledExecutorService scheduledExecutor,
ExecutorFactory executorFactory,
boolean syncNonTransactional,
IOCriticalErrorListener critialErrorListener) |
PagingStoreFactoryNIO(StorageManager storageManager,
File directory,
long syncTimeout,
ScheduledExecutorService scheduledExecutor,
ExecutorFactory executorFactory,
boolean syncNonTransactional,
IOCriticalErrorListener critialErrorListener) |
Modifier and Type | Field and Description |
---|---|
protected ExecutorFactory |
AbstractJournalStorageManager.executorFactory
Used to create Operation Contexts
|
protected ExecutorFactory |
AbstractJournalStorageManager.ioExecutors |
Modifier and Type | Method and Description |
---|---|
static OperationContext |
OperationContextImpl.getContext(ExecutorFactory executorFactory) |
Modifier and Type | Method and Description |
---|---|
ExecutorFactory |
InVMAcceptor.getExecutorFactory() |
Constructor and Description |
---|
ReplicationManager(CoreRemotingConnection remotingConnection,
long timeout,
long initialReplicationSyncTimeout,
ExecutorFactory executorFactory) |
Modifier and Type | Method and Description |
---|---|
ExecutorFactory |
ActiveMQServer.getExecutorFactory() |
ExecutorFactory |
ActiveMQServer.getIOExecutorFactory() |
Constructor and Description |
---|
BackupManager(ActiveMQServer server,
ExecutorFactory executorFactory,
ScheduledExecutorService scheduledExecutor,
NodeManager nodeManager,
Configuration configuration,
ClusterManager clusterManager) |
ClusterManager(ExecutorFactory executorFactory,
ActiveMQServer server,
PostOffice postOffice,
ScheduledExecutorService scheduledExecutor,
ManagementService managementService,
Configuration configuration,
NodeManager nodeManager,
boolean backup) |
Constructor and Description |
---|
ClusterConnectionImpl(ClusterManager manager,
DiscoveryGroupConfiguration dg,
TransportConfiguration connector,
SimpleString name,
SimpleString address,
int minLargeMessageSize,
long clientFailureCheckPeriod,
long connectionTTL,
long retryInterval,
double retryIntervalMultiplier,
long maxRetryInterval,
int initialConnectAttempts,
int reconnectAttempts,
long callTimeout,
long callFailoverTimeout,
boolean useDuplicateDetection,
MessageLoadBalancingType messageLoadBalancingType,
int confirmationWindowSize,
int producerWindowSize,
ExecutorFactory executorFactory,
ActiveMQServer server,
PostOffice postOffice,
ManagementService managementService,
ScheduledExecutorService scheduledExecutor,
int maxHops,
NodeManager nodeManager,
String clusterUser,
String clusterPassword,
boolean allowDirectConnectionsOnly,
long clusterNotificationInterval,
int clusterNotificationAttempts) |
ClusterConnectionImpl(ClusterManager manager,
TransportConfiguration[] staticTranspConfigs,
TransportConfiguration connector,
SimpleString name,
SimpleString address,
int minLargeMessageSize,
long clientFailureCheckPeriod,
long connectionTTL,
long retryInterval,
double retryIntervalMultiplier,
long maxRetryInterval,
int initialConnectAttempts,
int reconnectAttempts,
long callTimeout,
long callFailoverTimeout,
boolean useDuplicateDetection,
MessageLoadBalancingType messageLoadBalancingType,
int confirmationWindowSize,
int producerWindowSize,
ExecutorFactory executorFactory,
ActiveMQServer server,
PostOffice postOffice,
ManagementService managementService,
ScheduledExecutorService scheduledExecutor,
int maxHops,
NodeManager nodeManager,
String clusterUser,
String clusterPassword,
boolean allowDirectConnectionsOnly,
long clusterNotificationInterval,
int clusterNotificationAttempts) |
Constructor and Description |
---|
LocalGroupingHandler(ExecutorFactory executorFactory,
ScheduledExecutorService scheduledExecutor,
ManagementService managementService,
SimpleString name,
SimpleString address,
StorageManager storageManager,
long timeout,
long groupTimeout,
long reaperPeriod) |
RemoteGroupingHandler(ExecutorFactory executorFactory,
ManagementService managementService,
SimpleString name,
SimpleString address,
long timeout,
long groupTimeout) |
Modifier and Type | Field and Description |
---|---|
protected ExecutorFactory |
QueueFactoryImpl.executorFactory |
Modifier and Type | Method and Description |
---|---|
ExecutorFactory |
ActiveMQServerImpl.getExecutorFactory() |
ExecutorFactory |
ActiveMQServerImpl.getIOExecutorFactory() |
Constructor and Description |
---|
QueueFactoryImpl(ExecutorFactory executorFactory,
ScheduledExecutorService scheduledExecutor,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
StorageManager storageManager) |
Constructor and Description |
---|
JMSJournalStorageManagerImpl(ExecutorFactory ioExecutors,
ExecutorFactory executorFactory,
IDGenerator idGenerator,
Configuration config,
ReplicationManager replicator,
ScheduledExecutorService scheduledExecutorService,
IOCriticalErrorListener criticalErrorListener) |
Modifier and Type | Class and Description |
---|---|
class |
OrderedExecutorFactory
A factory for producing executors that run all tasks in order, which delegate to a single common executor instance.
|
Copyright © 2017 JBoss by Red Hat. All rights reserved.