Package org.elasticsearch.transport

Interface ConnectionManager

All Superinterfaces:

AutoCloseable, Closeable

All Known Implementing Classes:

ClusterConnectionManager, RemoteConnectionManager

public interface ConnectionManager
extends Closeable

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, ActionListener<Void> listener)
void	disconnectFromNode(DiscoveryNode node)
Set<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,
 ActionListener<Void> listener)
            throws ConnectTransportException

Throws:

ConnectTransportException

getConnection

Transport.Connection getConnection(DiscoveryNode node)

nodeConnected

boolean nodeConnected(DiscoveryNode node)

disconnectFromNode

void disconnectFromNode(DiscoveryNode node)

getAllConnectedNodes

Set<DiscoveryNode> getAllConnectedNodes()

size

int size()

close

void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

closeNoBlock

void closeNoBlock()

getConnectionProfile

ConnectionProfile getConnectionProfile()