Package org.elasticsearch.transport

Class ConnectionManager

java.lang.Object

org.elasticsearch.transport.ConnectionManager

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

public class ConnectionManager
extends java.lang.Object
implements java.io.Closeable

This class manages node connections. The connection is opened by the underlying transport. Once the connection is opened, this class manages the connection. This includes keep-alive pings and closing the connection when the connection manager is closed.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	ConnectionManager.ConnectionValidator

Constructor Summary

Constructors

Constructor	Description
ConnectionManager(Settings settings, Transport transport)
ConnectionManager(ConnectionProfile connectionProfile, Transport transport)

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<java.lang.Void> listener)	Connects to a node with the given connection profile.
void	disconnectFromNode(DiscoveryNode node)	Disconnected from the given node, if not connected, will do nothing.
java.util.Set<DiscoveryNode>	getAllConnectedNodes()
Transport.Connection	getConnection(DiscoveryNode node)	Returns a connection for the given node if the node is connected.
boolean	nodeConnected(DiscoveryNode node)	Returns true if the node is connected.
void	openConnection(DiscoveryNode node, ConnectionProfile connectionProfile, ActionListener<Transport.Connection> listener)
void	removeListener(TransportConnectionListener listener)
int	size()	Returns the number of nodes this manager is connected to.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ConnectionManager

public ConnectionManager(Settings settings, Transport transport)

ConnectionManager

public ConnectionManager(ConnectionProfile connectionProfile, Transport transport)

Method Details

addListener

public void addListener(TransportConnectionListener listener)

removeListener

public void removeListener(TransportConnectionListener listener)

openConnection

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

connectToNode

public void connectToNode(DiscoveryNode node, ConnectionProfile connectionProfile, ConnectionManager.ConnectionValidator connectionValidator, ActionListener<java.lang.Void> listener) throws ConnectTransportException

Connects to a node with the given connection profile. If the node is already connected this method has no effect. Once a successful is established, it can be validated before being exposed. The ActionListener will be called on the calling thread or the generic thread pool.

Throws:

ConnectTransportException

getConnection

public Transport.Connection getConnection(DiscoveryNode node)

Returns a connection for the given node if the node is connected. Connections returned from this method must not be closed. The lifecycle of this connection is maintained by this connection manager

Throws:

NodeNotConnectedException - if the node is not connected

See Also:

connectToNode(DiscoveryNode, ConnectionProfile, ConnectionValidator, ActionListener)

nodeConnected

public boolean nodeConnected(DiscoveryNode node)

Returns true if the node is connected.

disconnectFromNode

public void disconnectFromNode(DiscoveryNode node)

Disconnected from the given node, if not connected, will do nothing.

size

public int size()

Returns the number of nodes this manager is connected to.

getAllConnectedNodes

public java.util.Set<DiscoveryNode> getAllConnectedNodes()

close

public void close()

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.io.Closeable

closeNoBlock

public void closeNoBlock()