Package | Description |
---|---|
org.hornetq.core.paging.impl | |
org.hornetq.core.persistence.impl.journal | |
org.hornetq.core.remoting.impl.invm | |
org.hornetq.core.replication.impl | |
org.hornetq.core.server | |
org.hornetq.core.server.cluster.impl | |
org.hornetq.core.server.impl | |
org.hornetq.utils |
Utilities and helper classes.
|
Modifier and Type | Method and Description |
---|---|
protected ExecutorFactory |
PagingStoreFactoryNIO.getExecutorFactory() |
Constructor and Description |
---|
PagingStoreFactoryNIO(String directory,
long syncTimeout,
ScheduledExecutorService scheduledExecutor,
ExecutorFactory executorFactory,
boolean syncNonTransactional) |
PagingStoreFactoryNIO(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) |
JournalStorageManager(Configuration config,
ExecutorFactory executorFactory,
ReplicationManager replicator,
IOCriticalErrorListener criticalErrorListener) |
Modifier and Type | Method and Description |
---|---|
ExecutorFactory |
InVMAcceptor.getExecutorFactory() |
Constructor and Description |
---|
ReplicationManagerImpl(ClientSessionFactoryInternal sessionFactory,
ExecutorFactory executorFactory) |
Modifier and Type | Method and Description |
---|---|
ExecutorFactory |
HornetQServer.getExecutorFactory() |
Constructor and Description |
---|
ClusterConnectionImpl(ClusterManagerImpl 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,
boolean useDuplicateDetection,
boolean routeWhenNoConsumers,
int confirmationWindowSize,
ExecutorFactory executorFactory,
HornetQServer server,
PostOffice postOffice,
ManagementService managementService,
ScheduledExecutorService scheduledExecutor,
int maxHops,
UUID nodeUUID,
boolean backup,
String clusterUser,
String clusterPassword,
boolean allowDirectConnectionsOnly) |
ClusterConnectionImpl(ClusterManagerInternal manager,
TransportConfiguration[] tcConfigs,
TransportConfiguration connector,
SimpleString name,
SimpleString address,
int minLargeMessageSize,
long clientFailureCheckPeriod,
long connectionTTL,
long retryInterval,
double retryIntervalMultiplier,
long maxRetryInterval,
int reconnectAttempts,
long callTimeout,
boolean useDuplicateDetection,
boolean routeWhenNoConsumers,
int confirmationWindowSize,
ExecutorFactory executorFactory,
HornetQServer server,
PostOffice postOffice,
ManagementService managementService,
ScheduledExecutorService scheduledExecutor,
int maxHops,
UUID nodeUUID,
boolean backup,
String clusterUser,
String clusterPassword,
boolean allowDirectConnectionsOnly) |
ClusterManagerImpl(ExecutorFactory executorFactory,
HornetQServer server,
PostOffice postOffice,
ScheduledExecutorService scheduledExecutor,
ManagementService managementService,
Configuration configuration,
UUID nodeUUID,
boolean backup,
boolean clustered) |
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 © 2012 JBoss by Red Hat. All Rights Reserved.