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 |
---|
ClusterManager(ExecutorFactory executorFactory,
HornetQServer server,
PostOffice postOffice,
ScheduledExecutorService scheduledExecutor,
ManagementService managementService,
Configuration configuration,
NodeManager nodeManager,
boolean backup,
ExecutorService threadPool) |
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 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) |
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 |
---|
QuorumManager(ServerLocator serverLocator,
ExecutorService executor,
ScheduledExecutorService scheduledPool,
String identity,
NodeManager nodeManager) |
Copyright © 2015 JBoss, a division of Red Hat. All Rights Reserved.