- All Superinterfaces:
AutoCloseable,Closeable
- All Known Implementing Classes:
ClusterConnectionManager,RemoteConnectionManager
-
Nested Class Summary
Nested ClassesModifier and TypeInterfaceDescriptionstatic interfacestatic final class -
Method Summary
Modifier and TypeMethodDescriptionvoidaddListener(TransportConnectionListener listener) voidclose()voidvoidconnectToNode(DiscoveryNode node, ConnectionProfile connectionProfile, ConnectionManager.ConnectionValidator connectionValidator, ActionListener<Releasable> listener) voidgetConnection(DiscoveryNode node) booleannodeConnected(DiscoveryNode node) voidopenConnection(DiscoveryNode node, ConnectionProfile connectionProfile, ActionListener<Transport.Connection> listener) voidremoveListener(TransportConnectionListener listener) intsize()
-
Method Details
-
addListener
-
removeListener
-
openConnection
void openConnection(DiscoveryNode node, ConnectionProfile connectionProfile, ActionListener<Transport.Connection> listener) -
connectToNode
void connectToNode(DiscoveryNode node, @Nullable ConnectionProfile connectionProfile, ConnectionManager.ConnectionValidator connectionValidator, ActionListener<Releasable> listener) throws ConnectTransportException - Throws:
ConnectTransportException
-
getConnection
-
nodeConnected
-
disconnectFromNode
-
getAllConnectedNodes
Set<DiscoveryNode> getAllConnectedNodes() -
size
int size() -
close
void close()- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceCloseable
-
closeNoBlock
void closeNoBlock() -
getConnectionProfile
ConnectionProfile getConnectionProfile()
-