java.lang.Object
org.elasticsearch.core.AbstractRefCounted
org.elasticsearch.transport.CloseableConnection
org.elasticsearch.transport.TcpTransport.NodeChannels
- All Implemented Interfaces:
Closeable,AutoCloseable,RefCounted,Transport.Connection
- Enclosing class:
TcpTransport
-
Field Summary
Fields inherited from class org.elasticsearch.core.AbstractRefCounted
ALREADY_CLOSED_MESSAGE, INVALID_DECREF_MESSAGEFields inherited from interface org.elasticsearch.core.RefCounted
ALWAYS_REFERENCED -
Method Summary
Modifier and TypeMethodDescriptionvoidclose()getNode()The node this connection is associated withReturns the version of the data to communicate in this channel.voidsendRequest(long requestId, String action, TransportRequest request, TransportRequestOptions options) Sends the request to the node this connection is associated withtoString()Methods inherited from class org.elasticsearch.transport.CloseableConnection
addCloseListener, addRemovedListener, closeInternal, isClosed, onRemovedMethods inherited from class org.elasticsearch.core.AbstractRefCounted
alreadyClosed, decRef, hasReferences, incRef, mustIncRef, of, refCount, touch, tryIncRefMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface org.elasticsearch.core.RefCounted
decRef, hasReferences, incRef, mustIncRef, tryIncRefMethods inherited from interface org.elasticsearch.transport.Transport.Connection
getCacheKey
-
Method Details
-
getTransportVersion
Description copied from interface:Transport.ConnectionReturns the version of the data to communicate in this channel. -
getChannels
-
channel
-
close
public void close()- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceCloseable- Specified by:
closein interfaceTransport.Connection- Overrides:
closein classCloseableConnection
-
getNode
Description copied from interface:Transport.ConnectionThe node this connection is associated with -
sendRequest
public void sendRequest(long requestId, String action, TransportRequest request, TransportRequestOptions options) throws IOException, TransportException Description copied from interface:Transport.ConnectionSends the request to the node this connection is associated with- Parameters:
requestId- seeTransport.ResponseHandlers.add(TransportResponseHandler, Connection, String)for detailsaction- the action to executerequest- the request to sendoptions- request options to apply- Throws:
IOExceptionTransportException
-
toString
-