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,
ConnectionLifeCycleListener listener,
Executor threadPool,
ScheduledExecutorService scheduledThreadPool,
Map<String,ProtocolManager> protocolHandler) |
Constructor and Description |
---|
InVMAcceptor(ClusterConnection clusterConnection,
Map<String,Object> configuration,
BufferHandler handler,
ConnectionLifeCycleListener listener,
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,
ConnectionLifeCycleListener listener,
Executor threadPool,
ScheduledExecutorService scheduledThreadPool,
Map<String,ProtocolManager> protocolMap) |
Constructor and Description |
---|
NettyAcceptor(String name,
ClusterConnection clusterConnection,
Map<String,Object> configuration,
BufferHandler handler,
ConnectionLifeCycleListener listener,
ScheduledExecutorService scheduledThreadPool,
Map<String,ProtocolManager> protocolMap) |
Modifier and Type | Method and Description |
---|---|
void |
HornetQServer.startReplication(CoreRemotingConnection rc,
ClusterConnection clusterConnection,
Pair<TransportConfiguration,TransportConfiguration> pair,
boolean failBackRequest)
Starts replication.
|
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
A 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,
StorageManager storageManager,
SimpleString managementAddress,
SimpleString managementNotificationAddress,
MessageFlowRecord flowRecord,
TransportConfiguration connector) |
Modifier and Type | Method and Description |
---|---|
void |
HornetQServerImpl.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,
ConnectionLifeCycleListener listener,
Executor threadPool,
ScheduledExecutorService scheduledThreadPool,
Map<String,ProtocolManager> protocolMap)
Create a new instance of an Acceptor.
|
Copyright © 2017 JBoss, a division of Red Hat. All Rights Reserved.