Package org.elasticsearch.transport

Class RemoteConnectionManager

org.elasticsearch.transport.RemoteConnectionManager

All Implemented Interfaces:

, , ConnectionManager

public class RemoteConnectionManager
extends 
implements ConnectionManager

Nested Class Summary

Nested classes/interfaces inherited from interface org.elasticsearch.transport.ConnectionManager

ConnectionManager.ConnectionValidator, 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	getAnyRemoteConnection()
Transport.Connection	getConnection(DiscoveryNode node)
ConnectionProfile	getConnectionProfile()
boolean	nodeConnected(DiscoveryNode node)
void	openConnection(DiscoveryNode node, ConnectionProfile profile, ActionListener<Transport.Connection> listener)
void	removeListener(TransportConnectionListener listener)
int	size()

Methods inherited from class java.lang.

, , , , , , , , , ,

Method Details

connectToNode

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

Specified by:

connectToNode in interface ConnectionManager

Throws:

ConnectTransportException

addListener

public void addListener(TransportConnectionListener listener)

Specified by:

addListener in interface ConnectionManager

removeListener

public void removeListener(TransportConnectionListener listener)

Specified by:

removeListener in interface ConnectionManager

openConnection

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

Specified by:

openConnection in interface ConnectionManager

getConnection

public Transport.Connection getConnection(DiscoveryNode node)

Specified by:

getConnection in interface ConnectionManager

nodeConnected

public boolean nodeConnected(DiscoveryNode node)

Specified by:

nodeConnected in interface ConnectionManager

disconnectFromNode

public void disconnectFromNode(DiscoveryNode node)

Specified by:

disconnectFromNode in interface ConnectionManager

getConnectionProfile

public ConnectionProfile getConnectionProfile()

Specified by:

getConnectionProfile in interface ConnectionManager

getAnyRemoteConnection

public Transport.Connection getAnyRemoteConnection()

getAllConnectedNodes

public <DiscoveryNode> getAllConnectedNodes()

Specified by:

getAllConnectedNodes in interface ConnectionManager

size

public int size()

Specified by:

size in interface ConnectionManager

close

public void close()

Specified by:

in interface

Specified by:

in interface

Specified by:

close in interface ConnectionManager

closeNoBlock

public void closeNoBlock()

Specified by:

closeNoBlock in interface ConnectionManager