Package org.elasticsearch.transport

Class TcpTransport.NodeChannels

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

public final class TcpTransport.NodeChannels
extends CloseableConnection

Field Summary

Fields inherited from class org.elasticsearch.core.AbstractRefCounted

ALREADY_CLOSED_MESSAGE

Method Summary

Modifier and Type	Method	Description
TcpChannel	channel(TransportRequestOptions.Type type)
void	close()
List<TcpChannel>	getChannels()
DiscoveryNode	getNode()	The node this connection is associated with
Version	getVersion()	Returns the version of the node this connection was established with.
void	sendRequest(long requestId, String action, TransportRequest request, TransportRequestOptions options)	Sends the request to the node this connection is associated with
String	toString()

Methods inherited from class org.elasticsearch.transport.CloseableConnection

addCloseListener, addRemovedListener, closeInternal, isClosed, onRemoved

Methods inherited from class org.elasticsearch.core.AbstractRefCounted

alreadyClosed, decRef, hasReferences, incRef, of, refCount, touch, tryIncRef

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.elasticsearch.core.RefCounted

decRef, hasReferences, incRef, tryIncRef

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

getCacheKey

Method Details

getVersion

public Version getVersion()

Description copied from interface: Transport.Connection

Returns the version of the node this connection was established with.

getChannels

public List<TcpChannel> getChannels()

channel

public TcpChannel channel(TransportRequestOptions.Type type)

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface Transport.Connection

Overrides:

close in class CloseableConnection

getNode

public DiscoveryNode getNode()

Description copied from interface: Transport.Connection

The 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.Connection

Sends the request to the node this connection is associated with

Parameters:

requestId - see Transport.ResponseHandlers.add(ResponseContext) for details

action - the action to execute

request - the request to send

options - request options to apply

Throws:

NodeNotConnectedException - if the given node is not connected

IOException

TransportException

toString

public String toString()

Overrides:

toString in class Object