Package org.elasticsearch.transport.nio.channel

Class TcpNioSocketChannel

java.lang.Object

org.elasticsearch.transport.nio.channel.AbstractNioChannel<java.nio.channels.SocketChannel>

org.elasticsearch.transport.nio.channel.NioSocketChannel

org.elasticsearch.transport.nio.channel.TcpNioSocketChannel

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, Releasable, NioChannel, TcpChannel

public class TcpNioSocketChannel
extends NioSocketChannel
implements TcpChannel

Constructor Summary

Constructors

Constructor	Description
TcpNioSocketChannel(java.nio.channels.SocketChannel socketChannel, SocketSelector selector)

Method Summary

Modifier and Type	Method	Description
void	sendMessage(BytesReference reference, ActionListener<java.lang.Void> listener)
void	setSoLinger(int value)
java.lang.String	toString()

Methods inherited from class org.elasticsearch.transport.nio.channel.AbstractNioChannel

addCloseListener, close, getLocalAddress, getRawChannel, getSelectionKey, isOpen, register

Methods inherited from class org.elasticsearch.transport.nio.channel.NioSocketChannel

addConnectListener, closeFromSelector, finishConnect, getExceptionContext, getReadContext, getRemoteAddress, getSelector, getWriteContext, isConnectComplete, isReadable, isWritable, read, setContexts, write

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.elasticsearch.transport.TcpChannel

addCloseListener, close, getLocalAddress, isOpen

Constructor Detail

TcpNioSocketChannel

public TcpNioSocketChannel(java.nio.channels.SocketChannel socketChannel,
                           SocketSelector selector)
                    throws java.io.IOException

Throws:

java.io.IOException

Method Detail

sendMessage

public void sendMessage(BytesReference reference,
                        ActionListener<java.lang.Void> listener)

Specified by:

sendMessage in interface TcpChannel

setSoLinger

public void setSoLinger(int value)
                 throws java.io.IOException

Specified by:

setSoLinger in interface TcpChannel

Throws:

java.io.IOException

toString

public java.lang.String toString()

Overrides:

toString in class NioSocketChannel