Modifier and Type | Method and Description |
---|---|
NodeManager |
ActiveMQServer.getNodeManager() |
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 |
---|
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,
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 |
---|
SharedNothingBackupQuorum(NodeManager nodeManager,
ScheduledExecutorService scheduledPool,
NetworkHealthCheck networkHealthCheck,
int quorumSize,
int voteRetries,
long voteRetryWait,
int quorumVoteWait,
boolean failback) |
Modifier and Type | Class and Description |
---|---|
class |
FileBasedNodeManager |
class |
FileLockNodeManager |
class |
InVMNodeManager
NodeManager used to run multiple servers in the same VM.
|
Modifier and Type | Field and Description |
---|---|
protected NodeManager |
PostOfficeJournalLoader.nodeManager |
Modifier and Type | Method and Description |
---|---|
protected NodeManager |
ActiveMQServerImpl.createNodeManager(File directory,
boolean replicatingBackup) |
NodeManager |
ActiveMQServerImpl.getNodeManager() |
Modifier and Type | Method and Description |
---|---|
JournalLoader |
Activation.createJournalLoader(PostOffice postOffice,
PagingManager pagingManager,
StorageManager storageManager,
QueueFactory queueFactory,
NodeManager nodeManager,
ManagementService managementService,
GroupingHandler groupingHandler,
Configuration configuration,
ActiveMQServer parentServer) |
JournalLoader |
SharedNothingBackupActivation.createJournalLoader(PostOffice postOffice,
PagingManager pagingManager,
StorageManager storageManager,
QueueFactory queueFactory,
NodeManager nodeManager,
ManagementService managementService,
GroupingHandler groupingHandler,
Configuration configuration,
ActiveMQServer parentServer) |
JournalLoader |
SharedStoreBackupActivation.createJournalLoader(PostOffice postOffice,
PagingManager pagingManager,
StorageManager storageManager,
QueueFactory queueFactory,
NodeManager nodeManager,
ManagementService managementService,
GroupingHandler groupingHandler,
Configuration configuration,
ActiveMQServer parentServer) |
void |
ActiveMQServerImpl.interruptActivationThread(NodeManager nodeManagerInUse) |
Constructor and Description |
---|
BackupRecoveryJournalLoader(PostOffice postOffice,
PagingManager pagingManager,
StorageManager storageManager,
QueueFactory queueFactory,
NodeManager nodeManager,
ManagementService managementService,
GroupingHandler groupingHandler,
Configuration configuration,
ActiveMQServer parentServer,
ServerLocatorInternal locator,
ClusterController clusterController) |
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) |
ScaleDownHandler(PagingManager pagingManager,
PostOffice postOffice,
NodeManager nodeManager,
ClusterController clusterController,
StorageManager storageManager) |
Modifier and Type | Class and Description |
---|---|
class |
JdbcNodeManager
JDBC implementation of
NodeManager . |
Copyright © 2021 JBoss by Red Hat. All rights reserved.