Package org.elasticsearch.transport

Interface ConnectionManager

All Superinterfaces:

,

All Known Implementing Classes:

ClusterConnectionManager, RemoteConnectionManager

public interface ConnectionManager
extends 

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	ConnectionManager.ConnectionValidator
static class	ConnectionManager.DelegatingNodeConnectionListener

Method Summary

Modifier and Type	Method	Description
void	addListener(TransportConnectionListener listener)
void	close()
void	closeNoBlock()
void	connectToNode(DiscoveryNode node, ConnectionProfile connectionProfile, ConnectionManager.ConnectionValidator connectionValidator, > listener)
void	disconnectFromNode(DiscoveryNode node)
<DiscoveryNode>	getAllConnectedNodes()
Transport.Connection	getConnection(DiscoveryNode node)
ConnectionProfile	getConnectionProfile()
boolean	nodeConnected(DiscoveryNode node)
void	openConnection(DiscoveryNode node, ConnectionProfile connectionProfile, ActionListener<Transport.Connection> listener)
void	removeListener(TransportConnectionListener listener)
int	size()

Method Details

addListener

void addListener(TransportConnectionListener listener)

removeListener

void removeListener(TransportConnectionListener listener)

openConnection

void openConnection(DiscoveryNode node,
 ConnectionProfile connectionProfile,
 ActionListener<Transport.Connection> listener)

connectToNode

void connectToNode(DiscoveryNode node,
 ConnectionProfile connectionProfile,
 ConnectionManager.ConnectionValidator connectionValidator,
 > listener)
            throws ConnectTransportException

Throws:

ConnectTransportException

getConnection

Transport.Connection getConnection(DiscoveryNode node)

nodeConnected

boolean nodeConnected(DiscoveryNode node)

disconnectFromNode

void disconnectFromNode(DiscoveryNode node)

getAllConnectedNodes

<DiscoveryNode> getAllConnectedNodes()

size

int size()

close

void close()

Specified by:

in interface

Specified by:

in interface

closeNoBlock

void closeNoBlock()

getConnectionProfile

ConnectionProfile getConnectionProfile()