Package org.elasticsearch.transport

Class CloseableConnection

java.lang.Object

org.elasticsearch.transport.CloseableConnection

All Implemented Interfaces:

Closeable, AutoCloseable, Transport.Connection

Direct Known Subclasses:

TcpTransport.NodeChannels

public abstract class CloseableConnection
extends Object
implements Transport.Connection

Abstract Transport.Connection that provides common close logic.

Constructor Summary

Constructors

Constructor	Description
CloseableConnection()

Method Summary

Modifier and Type	Method	Description
void	addCloseListener(ActionListener<Void> listener)	The listener's ActionListener.onResponse(Object) method will be called when this connection is closed.
void	close()
boolean	isClosed()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.elasticsearch.transport.Transport.Connection

getCacheKey, getNode, getVersion, sendRequest

Constructor Details

CloseableConnection

public CloseableConnection()

Method Details

addCloseListener

public void addCloseListener(ActionListener<Void> listener)

Description copied from interface: Transport.Connection

The listener's ActionListener.onResponse(Object) method will be called when this connection is closed. No implementations currently throw an exception during close, so ActionListener.onFailure(Exception) will not be called.

Specified by:

addCloseListener in interface Transport.Connection

Parameters:

listener - to be called

isClosed

public boolean isClosed()

Specified by:

isClosed in interface Transport.Connection

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface Transport.Connection