Constructor and Description |
---|
PagingStoreFactoryNIO(StorageManager storageManager,
String directory,
long syncTimeout,
ScheduledExecutorService scheduledExecutor,
ExecutorFactory executorFactory,
boolean syncNonTransactional,
IOCriticalErrorListener critialErrorListener) |
Modifier and Type | Method and Description |
---|---|
static OperationContext |
OperationContextImpl.getContext(ExecutorFactory executorFactory) |
Constructor and Description |
---|
JournalStorageManager(Configuration config,
ExecutorFactory executorFactory) |
JournalStorageManager(Configuration config,
ExecutorFactory executorFactory,
IOCriticalErrorListener criticalErrorListener) |
Modifier and Type | Method and Description |
---|---|
ExecutorFactory |
InVMAcceptor.getExecutorFactory() |
Constructor and Description |
---|
ReplicationManager(CoreRemotingConnection remotingConnection,
ExecutorFactory executorFactory) |
Modifier and Type | Method and Description |
---|---|
ExecutorFactory |
HornetQServer.getExecutorFactory() |
Constructor and Description |
---|
ClusterManager(ExecutorFactory executorFactory,
HornetQServer server,
PostOffice postOffice,
ScheduledExecutorService scheduledExecutor,
ManagementService managementService,
Configuration configuration,
NodeManager nodeManager,
boolean backup,
ExecutorService threadPool) |
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 reconnectAttempts,
long callTimeout,
long callFailoverTimeout,
boolean useDuplicateDetection,
boolean routeWhenNoConsumers,
int confirmationWindowSize,
ExecutorFactory executorFactory,
ExecutorService threadPool,
HornetQServer server,
PostOffice postOffice,
ManagementService managementService,
ScheduledExecutorService scheduledExecutor,
int maxHops,
NodeManager nodeManager,
boolean backup,
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 reconnectAttempts,
long callTimeout,
long callFailoverTimeout,
boolean useDuplicateDetection,
boolean routeWhenNoConsumers,
int confirmationWindowSize,
ExecutorFactory executorFactory,
ExecutorService threadPool,
HornetQServer server,
PostOffice postOffice,
ManagementService managementService,
ScheduledExecutorService scheduledExecutor,
int maxHops,
NodeManager nodeManager,
boolean backup,
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) |
Modifier and Type | Field and Description |
---|---|
protected ExecutorFactory |
QueueFactoryImpl.executorFactory |
Modifier and Type | Method and Description |
---|---|
ExecutorFactory |
HornetQServerImpl.getExecutorFactory() |
Constructor and Description |
---|
QueueFactoryImpl(ExecutorFactory executorFactory,
ScheduledExecutorService scheduledExecutor,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
StorageManager storageManager) |
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 © 2013 JBoss by Red Hat. All Rights Reserved.