org.elasticsearch.transport

Class TcpTransport.NodeChannels

java.lang.Object

org.elasticsearch.transport.TcpTransport.NodeChannels

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, Transport.Connection

Enclosing class:

TcpTransport<Channel>

public final class TcpTransport.NodeChannels
extends java.lang.Object
implements Transport.Connection

Constructor Summary

Constructors

Constructor and Description
NodeChannels(DiscoveryNode node, Channel[] channels, ConnectionProfile connectionProfile)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

NodeChannels

public NodeChannels(DiscoveryNode node,
                    Channel[] channels,
                    ConnectionProfile connectionProfile)

Method Detail

getVersion

public Version getVersion()

Description copied from interface: Transport.Connection

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

Specified by:

getVersion in interface Transport.Connection

hasChannel

public boolean hasChannel(Channel channel)

getChannels

public java.util.List<Channel> getChannels()

channel

public Channel channel(TransportRequestOptions.Type type)

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.io.IOException

getNode

public DiscoveryNode getNode()

Description copied from interface: Transport.Connection

The node this connection is associated with

Specified by:

getNode in interface Transport.Connection

sendRequest

public void sendRequest(long requestId,
                        java.lang.String action,
                        TransportRequest request,
                        TransportRequestOptions options)
                 throws java.io.IOException,
                        TransportException

Description copied from interface: Transport.Connection

Sends the request to the node this connection is associated with

Specified by:

sendRequest in interface Transport.Connection

Throws:

NodeNotConnectedException - if the given node is not connected

java.io.IOException

TransportException