Constructor and Description |
---|
ClusterConnectionControlImpl(ClusterConnection clusterConnection,
StorageManager storageManager,
ClusterConnectionConfiguration configuration) |
Modifier and Type | Method and Description |
---|---|
ClusterConnection |
InVMAcceptor.getClusterConnection() |
Modifier and Type | Method and Description |
---|---|
Acceptor |
InVMAcceptorFactory.createAcceptor(String name,
ClusterConnection clusterConnection,
Map<String,Object> configuration,
BufferHandler handler,
ServerConnectionLifeCycleListener listener,
Executor threadPool,
ScheduledExecutorService scheduledThreadPool,
Map<String,ProtocolManager> protocolMap) |
Constructor and Description |
---|
InVMAcceptor(String name,
ClusterConnection clusterConnection,
Map<String,Object> configuration,
BufferHandler handler,
ServerConnectionLifeCycleListener listener,
Map<String,ProtocolManager> protocolMap,
Executor threadPool) |
Modifier and Type | Method and Description |
---|---|
ClusterConnection |
NettyAcceptor.getClusterConnection() |
Modifier and Type | Method and Description |
---|---|
Acceptor |
NettyAcceptorFactory.createAcceptor(String name,
ClusterConnection connection,
Map<String,Object> configuration,
BufferHandler handler,
ServerConnectionLifeCycleListener listener,
Executor threadPool,
ScheduledExecutorService scheduledThreadPool,
Map<String,ProtocolManager> protocolMap) |
Constructor and Description |
---|
NettyAcceptor(String name,
ClusterConnection clusterConnection,
Map<String,Object> configuration,
BufferHandler handler,
ServerConnectionLifeCycleListener listener,
ScheduledExecutorService scheduledThreadPool,
Executor failureExecutor,
Map<String,ProtocolManager> protocolMap) |
Modifier and Type | Method and Description |
---|---|
ClusterConnection |
ClusterManager.getClusterConnection(String name) |
ClusterConnection |
ClusterManager.getDefaultConnection(TransportConfiguration acceptorConfig)
Return the default ClusterConnection to be used case it's not defined by the acceptor
|
Modifier and Type | Method and Description |
---|---|
Set<ClusterConnection> |
ClusterManager.getClusterConnections() |
Modifier and Type | Class and Description |
---|---|
class |
ClusterConnectionImpl |
Constructor and Description |
---|
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) |
Modifier and Type | Method and Description |
---|---|
void |
SharedNothingLiveActivation.startReplication(CoreRemotingConnection rc,
ClusterConnection clusterConnection,
Pair<TransportConfiguration,TransportConfiguration> pair,
boolean isFailBackRequest) |
Modifier and Type | Method and Description |
---|---|
void |
ManagementService.registerCluster(ClusterConnection cluster,
ClusterConnectionConfiguration configuration) |
Modifier and Type | Method and Description |
---|---|
void |
ManagementServiceImpl.registerCluster(ClusterConnection cluster,
ClusterConnectionConfiguration configuration) |
Modifier and Type | Method and Description |
---|---|
ClusterConnection |
Acceptor.getClusterConnection() |
Modifier and Type | Method and Description |
---|---|
Acceptor |
AcceptorFactory.createAcceptor(String name,
ClusterConnection clusterConnection,
Map<String,Object> configuration,
BufferHandler handler,
ServerConnectionLifeCycleListener listener,
Executor threadPool,
ScheduledExecutorService scheduledThreadPool,
Map<String,ProtocolManager> protocolMap)
Create a new instance of an Acceptor.
|
Copyright © 2018 JBoss by Red Hat. All rights reserved.