Package org.elasticsearch.transport
Interface Transport.Connection
- All Superinterfaces:
,
- All Known Implementing Classes:
CloseableConnection
,TcpTransport.NodeChannels
- Enclosing interface:
- Transport
public static interface Transport.Connection
extends
A unidirectional connection to a
DiscoveryNode
-
Method Summary
Modifier and TypeMethodDescriptionvoid
> listener)
The listener'sActionListener.onResponse(Object)
method will be called when this connection is closed.void
close()
default
Returns a key that this connection can be cached on.getNode()
The node this connection is associated withdefault Version
Returns the version of the node this connection was established with.boolean
isClosed()
void
sendRequest(long requestId, action, TransportRequest request, TransportRequestOptions options)
Sends the request to the node this connection is associated with
-
Method Details
-
getNode
DiscoveryNode getNode()The node this connection is associated with -
sendRequest
void sendRequest(long requestId, action, TransportRequest request, TransportRequestOptions options) throws , TransportExceptionSends 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 connectedTransportException
-
addCloseListener
void addCloseListener(> listener)The listener'sActionListener.onResponse(Object)
method will be called when this connection is closed. No implementations currently throw an exception during close, soActionListener.onFailure(Exception)
will not be called.- Parameters:
listener
- to be called
-
isClosed
boolean isClosed() -
getVersion
Returns the version of the node this connection was established with. -
getCacheKey
default getCacheKey()Returns a key that this connection can be cached on. Delegating subclasses must delegate method call to the original connection. -
close
void close()- Specified by:
in interface
- Specified by:
in interface
-