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(ClusterConnection clusterConnection,
Map<String,Object> configuration,
BufferHandler handler,
BufferDecoder decoder,
ConnectionLifeCycleListener listener,
Executor threadPool,
ScheduledExecutorService scheduledThreadPool) |
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(ClusterConnection connection,
Map<String,Object> configuration,
BufferHandler handler,
BufferDecoder decoder,
ConnectionLifeCycleListener listener,
Executor threadPool,
ScheduledExecutorService scheduledThreadPool) |
Constructor and Description |
---|
NettyAcceptor(ClusterConnection clusterConnection,
Map<String,Object> configuration,
BufferHandler handler,
BufferDecoder decoder,
ConnectionLifeCycleListener listener,
Executor threadPool,
ScheduledExecutorService scheduledThreadPool) |
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 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,
boolean activated,
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(ClusterConnection clusterConnection,
Map<String,Object> configuration,
BufferHandler handler,
BufferDecoder decoder,
ConnectionLifeCycleListener listener,
Executor threadPool,
ScheduledExecutorService scheduledThreadPool)
Create a new instance of an Acceptor.
|
Copyright © 2014 JBoss by Red Hat. All Rights Reserved.