Package org.elasticsearch.transport
Class TcpTransport.NodeChannels
java.lang.Object
org.elasticsearch.transport.CloseableConnection
org.elasticsearch.transport.TcpTransport.NodeChannels
- All Implemented Interfaces:
java.io.Closeable
,java.lang.AutoCloseable
,Transport.Connection
- Enclosing class:
- TcpTransport
public final class TcpTransport.NodeChannels extends CloseableConnection
-
Method Summary
Modifier and Type Method Description TcpChannel
channel(TransportRequestOptions.Type type)
void
close()
java.util.List<TcpChannel>
getChannels()
DiscoveryNode
getNode()
The node this connection is associated withVersion
getVersion()
Returns the version of the node this connection was established with.void
sendRequest(long requestId, java.lang.String action, TransportRequest request, TransportRequestOptions options)
Sends the request to the node this connection is associated withMethods inherited from class org.elasticsearch.transport.CloseableConnection
addCloseListener, 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
-
Method Details
-
getVersion
Description copied from interface:Transport.Connection
Returns the version of the node this connection was established with. -
getChannels
-
channel
-
close
public void close()- Specified by:
close
in interfacejava.lang.AutoCloseable
- Specified by:
close
in interfacejava.io.Closeable
- Specified by:
close
in interfaceTransport.Connection
- Overrides:
close
in classCloseableConnection
-
getNode
Description copied from interface:Transport.Connection
The node this connection is associated with -
sendRequest
public void sendRequest(long requestId, java.lang.String action, TransportRequest request, TransportRequestOptions options) throws java.io.IOException, TransportExceptionDescription copied from interface:Transport.Connection
Sends the request to the node this connection is associated with- Parameters:
requestId
- seeTransport.ResponseHandlers.add(ResponseContext)
for detailsaction
- the action to executerequest
- the request to sendoptions
- request options to apply- Throws:
NodeNotConnectedException
- if the given node is not connectedjava.io.IOException
TransportException
-