Package org.elasticsearch.transport

Class ConnectionManager.DelegatingNodeConnectionListener

org.elasticsearch.transport.ConnectionManager.DelegatingNodeConnectionListener

All Implemented Interfaces:

TransportConnectionListener

Enclosing interface:

ConnectionManager

public static final class ConnectionManager.DelegatingNodeConnectionListener
extends 
implements TransportConnectionListener

Constructor Summary

Constructors

Constructor	Description
DelegatingNodeConnectionListener()

Method Summary

Modifier and Type	Method	Description
void	addListener(TransportConnectionListener listener)
void	onConnectionClosed(Transport.Connection connection)	Called once a connection ws closed.
void	onConnectionOpened(Transport.Connection connection)	Called once a connection was opened
void	onNodeConnected(DiscoveryNode node, Transport.Connection connection)	Called once a node connection is opened and registered.
void	onNodeDisconnected(DiscoveryNode key, Transport.Connection connection)	Called once a node connection is closed and unregistered.
void	removeListener(TransportConnectionListener listener)

Methods inherited from class java.lang.

, , , , , , , , , ,

Constructor Details

DelegatingNodeConnectionListener

public DelegatingNodeConnectionListener()

Method Details

onNodeDisconnected

public void onNodeDisconnected(DiscoveryNode key,
 Transport.Connection connection)

Description copied from interface: TransportConnectionListener

Called once a node connection is closed and unregistered.

Specified by:

onNodeDisconnected in interface TransportConnectionListener

onNodeConnected

public void onNodeConnected(DiscoveryNode node,
 Transport.Connection connection)

Description copied from interface: TransportConnectionListener

Called once a node connection is opened and registered.

Specified by:

onNodeConnected in interface TransportConnectionListener

onConnectionOpened

public void onConnectionOpened(Transport.Connection connection)

Description copied from interface: TransportConnectionListener

Called once a connection was opened

Specified by:

onConnectionOpened in interface TransportConnectionListener

Parameters:

connection - the connection

onConnectionClosed

public void onConnectionClosed(Transport.Connection connection)

Description copied from interface: TransportConnectionListener

Called once a connection ws closed.

Specified by:

onConnectionClosed in interface TransportConnectionListener

Parameters:

connection - the closed connection

addListener

public void addListener(TransportConnectionListener listener)

removeListener

public void removeListener(TransportConnectionListener listener)