Package org.elasticsearch.transport
Class ConnectionManager.DelegatingNodeConnectionListener
java.lang.Object
org.elasticsearch.transport.ConnectionManager.DelegatingNodeConnectionListener
- All Implemented Interfaces:
TransportConnectionListener
- Enclosing interface:
- ConnectionManager
public static final class ConnectionManager.DelegatingNodeConnectionListener
extends Object
implements TransportConnectionListener
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
addListener(TransportConnectionListener listener)
void
onConnectionClosed(Transport.Connection connection)
Called once a connection ws closed.void
onConnectionOpened(Transport.Connection connection)
Called once a connection was openedvoid
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)
-
Constructor Details
-
DelegatingNodeConnectionListener
public DelegatingNodeConnectionListener()
-
-
Method Details
-
onNodeDisconnected
Description copied from interface:TransportConnectionListener
Called once a node connection is closed and unregistered.- Specified by:
onNodeDisconnected
in interfaceTransportConnectionListener
-
onNodeConnected
Description copied from interface:TransportConnectionListener
Called once a node connection is opened and registered.- Specified by:
onNodeConnected
in interfaceTransportConnectionListener
-
onConnectionOpened
Description copied from interface:TransportConnectionListener
Called once a connection was opened- Specified by:
onConnectionOpened
in interfaceTransportConnectionListener
- Parameters:
connection
- the connection
-
onConnectionClosed
Description copied from interface:TransportConnectionListener
Called once a connection ws closed.- Specified by:
onConnectionClosed
in interfaceTransportConnectionListener
- Parameters:
connection
- the closed connection
-
addListener
-
removeListener
-