Modifier and Type | Class and Description |
---|---|
class |
ServerLocatorImpl
This is the implementation of
ServerLocator and all
the proper javadoc is located on that interface. |
Modifier and Type | Method and Description |
---|---|
ServerLocatorInternal |
ServerLocatorInternal.setAfterConnectionInternalListener(AfterConnectInternalListener listener) |
ServerLocatorInternal |
ServerLocatorInternal.setClusterConnection(boolean clusterConnection) |
ServerLocatorInternal |
ServerLocatorInternal.setClusterTransportConfiguration(TransportConfiguration tc) |
ServerLocatorInternal |
ServerLocatorInternal.setIdentity(String identity)
Used to better identify Cluster Connection Locators on logs.
|
ServerLocatorInternal |
ServerLocatorInternal.setNodeID(String nodeID) |
Constructor and Description |
---|
ClientSessionFactoryImpl(ServerLocatorInternal serverLocator,
TransportConfiguration connectorConfig,
long callTimeout,
long callFailoverTimeout,
long clientFailureCheckPeriod,
long connectionTTL,
long retryInterval,
double retryIntervalMultiplier,
long maxRetryInterval,
int reconnectAttempts,
Executor threadPool,
ScheduledExecutorService scheduledThreadPool,
List<Interceptor> incomingInterceptors,
List<Interceptor> outgoingInterceptors) |
Modifier and Type | Method and Description |
---|---|
void |
LiveNodeLocator.connectToCluster(ServerLocatorInternal serverLocator)
connects to the cluster
|
void |
ActiveMQServerLogger.errorClosingServerLocator(Exception e,
ServerLocatorInternal clusterLocator) |
Modifier and Type | Method and Description |
---|---|
void |
ClusterManager.removeClusterLocator(ServerLocatorInternal serverLocator) |
Modifier and Type | Method and Description |
---|---|
static ServerLocatorInternal |
ScaleDownPolicy.getScaleDownConnector(ScaleDownPolicy scaleDownPolicy,
ActiveMQServer activeMQServer) |
Modifier and Type | Field and Description |
---|---|
protected ServerLocatorInternal |
BridgeImpl.serverLocator |
Constructor and Description |
---|
BridgeImpl(ServerLocatorInternal serverLocator,
int initialConnectAttempts,
int reconnectAttempts,
int reconnectAttemptsSameNode,
long retryInterval,
double retryMultiplier,
long maxRetryInterval,
UUID nodeUUID,
SimpleString name,
Queue queue,
Executor executor,
Filter filter,
SimpleString forwardingAddress,
ScheduledExecutorService scheduledExecutor,
Transformer transformer,
boolean useDuplicateDetection,
String user,
String password,
ActiveMQServer server) |
ClusterConnectionBridge(ClusterConnection clusterConnection,
ClusterManager clusterManager,
ServerLocatorInternal targetLocator,
ServerLocatorInternal discoveryLocator,
int initialConnectAttempts,
int reconnectAttempts,
long retryInterval,
double retryMultiplier,
long maxRetryInterval,
UUID nodeUUID,
long targetNodeEventUID,
String targetNodeID,
SimpleString name,
Queue queue,
Executor executor,
Filter filterString,
SimpleString forwardingAddress,
ScheduledExecutorService scheduledExecutor,
Transformer transformer,
boolean useDuplicateDetection,
String user,
String password,
ActiveMQServer server,
SimpleString managementAddress,
SimpleString managementNotificationAddress,
MessageFlowRecord flowRecord,
TransportConfiguration connector,
String storeAndForwardPrefix) |
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) |
Copyright © 2018 JBoss by Red Hat. All rights reserved.