Package | Description |
---|---|
org.hornetq.core.server | |
org.hornetq.core.server.cluster | |
org.hornetq.core.server.cluster.impl | |
org.hornetq.core.server.impl |
Modifier and Type | Method and Description |
---|---|
NodeManager |
HornetQServer.getNodeManager() |
Constructor and Description |
---|
BackupManager(HornetQServer server,
ExecutorFactory executorFactory,
ScheduledExecutorService scheduledExecutor,
NodeManager nodeManager,
Configuration configuration,
ClusterManager clusterManager) |
ClusterManager(ExecutorFactory executorFactory,
HornetQServer server,
PostOffice postOffice,
ScheduledExecutorService scheduledExecutor,
ManagementService managementService,
Configuration configuration,
NodeManager nodeManager,
boolean backup) |
Constructor and Description |
---|
BroadcastGroupImpl(NodeManager nodeManager,
String name,
long broadCastPeriod,
ScheduledExecutorService scheduledExecutor,
BroadcastEndpointFactory endpointFactory) |
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,
boolean routeWhenNoConsumers,
int confirmationWindowSize,
ExecutorFactory executorFactory,
HornetQServer 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,
boolean routeWhenNoConsumers,
int confirmationWindowSize,
ExecutorFactory executorFactory,
HornetQServer server,
PostOffice postOffice,
ManagementService managementService,
ScheduledExecutorService scheduledExecutor,
int maxHops,
NodeManager nodeManager,
String clusterUser,
String clusterPassword,
boolean allowDirectConnectionsOnly,
long clusterNotificationInterval,
int clusterNotificationAttempts) |
Modifier and Type | Class and Description |
---|---|
class |
AIOFileLockNodeManager
This is using the HornetQ Libaio Native to perform calls to flock on a Linux system.
|
class |
FileLockNodeManager |
Modifier and Type | Method and Description |
---|---|
protected NodeManager |
HornetQServerImpl.createNodeManager(String directory,
String nodeGroupName,
boolean replicatingBackup) |
NodeManager |
HornetQServerImpl.getNodeManager() |
Constructor and Description |
---|
PostOfficeJournalLoader(PostOffice postOffice,
PagingManager pagingManager,
StorageManager storageManager,
QueueFactory queueFactory,
NodeManager nodeManager,
ManagementService managementService,
GroupingHandler groupingHandler,
Configuration configuration) |
PostOfficeJournalLoader(PostOffice postOffice,
PagingManager pagingManager,
StorageManager storageManager,
QueueFactory queueFactory,
NodeManager nodeManager,
ManagementService managementService,
GroupingHandler groupingHandler,
Configuration configuration,
Map<Long,Queue> queues) |
QuorumManager(ServerLocator serverLocator,
ExecutorService executor,
ScheduledExecutorService scheduledPool,
String identity,
NodeManager nodeManager) |
Copyright © 2017 JBoss, a division of Red Hat. All Rights Reserved.